• Status: Solved
  • Priority: Medium
  • Security: Public
  • Views: 161
  • Last Modified:

How do I create make a series of Queue's accessible to multiple classes?

Hi,

How do I create make a series of Queue's accessible to multiple classes?

I.e.

1. One part of the application has data fed in;

2. The application stores this information into a Queue;

3. This Queue just keeps on building with new data - lets say *a lot* of data is being added every second.

4. (Stuck on this) I have classes with code ready to manipulate this data and send it to a DB (store it) and a management application (do-something) via SqlConnection and TCP respectively.

I intend:

Several threads will be "active" using these classes, each using `aString = aQueue.Dequeue()`, and then manipulating aString before sending it off over the wire. Taking the data from the Queue obviously stops other threads getting it.

Multiple threads will be used to try and ensure the queue is always as empty as possible. Going across a network will take at least a few MS, which obviously is not going to be burning processing time... that can instead be used to manipulate the next item.

For this method to work, all threads need to use a centralised "store" - the Queue(s) - and strip off one piece of work at a time (thus Dequeue).

So what you will have happening is data being added to queues from a.disperate.source, and then several threads looking at this queue to pull the information apart… continuously.

So.. The question is: **How** do I make it so these Queues can be accessed by the thread adding data in, and also the threads taking data out?

Any input gratefully received..!

Cheers

**Note: **

Error when trying public static:
cannot declare instance members in a static class

Error when using public:
An object reference is required for the nonstatic field, method, or property
( Can an instance of the class be made, and then accessed by everything else… data adder class + handler classes and the threaded instances of them? If so... how?)
0
James_15
Asked:
James_15
1 Solution
 
Mike TomlinsonMiddle School Assistant TeacherCommented:
Declare a static member in a normal class like this:

    public class DataStore
    {
        public static Queue aQueue = new Queue();
    }

    public partial class Form1 : Form
    {

        private void button1_Click(object sender, EventArgs e)
        {
            DataStore.aQueue.Enqueue("a");
            DataStore.aQueue.Enqueue("b");
            DataStore.aQueue.Enqueue("c");

            while (DataStore.aQueue.Count > 0) {
                System.Diagnostics.Debug.Print((string)DataStore.aQueue.Dequeue());
                Application.DoEvents();
                System.Threading.Thread.Sleep(1000);
            }
        }

    }
0
 
James_15Author Commented:
Perfect - cheers!
0

Featured Post

The new generation of project management tools

With monday.com’s project management tool, you can see what everyone on your team is working in a single glance. Its intuitive dashboards are customizable, so you can create systems that work for you.

Tackle projects and never again get stuck behind a technical roadblock.
Join Now