C#

public class Producer
{
    Capture capture;
    Queue<Image<Bgr, Byte>> inQueue;
    Queue<Image<Bgr, Byte>> outQueue;
    Object lockObject;
    Emgu.CV.UI.ImageBox screen;
    public int frameCounter = 0;

    public Producer(Emgu.CV.UI.ImageBox screen, Capture capture, Queue<Image<Bgr, Byte>> inQueue, Queue<Image<Bgr, Byte>> outQueue, Object lockObject)
    {
        this.screen = screen;
        this.capture = capture;
        this.inQueue = inQueue;
        this.outQueue = outQueue;
        this.lockObject = lockObject;
    }

    public void produce()
    {
        while (true)
        {
            lock (lockObject)
            {
                inQueue.Enqueue(capture.QueryFrame());

                if (inQueue.Count == 1)
                {
                    Monitor.PulseAll(lockObject);
                }
                if (outQueue.Count > 0)
                {
                    screen.Image = outQueue.Dequeue();
                }
            }
            frameCounter++;
        }
    }
}

public class Consumer
{
    Queue<Image<Bgr, Byte>> inQueue;
    Queue<Image<Bgr, Byte>> outQueue;
    Object lockObject;
    string name;

    Image<Bgr, Byte> image;

    public Consumer(Queue<Image<Bgr, Byte>> inQueue, Queue<Image<Bgr, Byte>> outQueue, Object lockObject, string name)
    {
        this.inQueue = inQueue;
        this.outQueue = outQueue;
        this.lockObject = lockObject;
        this.name = name;
    }

    public void consume()
    {
        while (true)
        {
            lock (lockObject)
            {
                if (inQueue.Count == 0)
                {
                    Monitor.Wait(lockObject);
                    continue;
                }
                image = inQueue.Dequeue();
            }

            // Do some heavy processing with the image

            lock (lockObject)
            {
                outQueue.Enqueue(image);
            }

        }
    }
}

private void Form1_Load(object sender, EventArgs e)
{
    Consumer[] c = new Consumer[consumerCount];
    Thread[] t = new Thread[consumerCount];

    Object lockObj = new object();
    Queue<Image<Bgr, Byte>> inQueue = new Queue<Image<Bgr, Byte>>();
    Queue<Image<Bgr, Byte>> outQueue = new Queue<Image<Bgr, Byte>>();

    p = new Producer(screen1, capture, inQueue, outQueue, lockObj);

    for (int i = 0; i < consumerCount; i++)
    {
        c[i] = new Consumer(inQueue, outQueue, lockObj, "c_" + Convert.ToString(i));
    }
    for (int i = 0; i < consumerCount; i++)
    {
        t[i] = new Thread(c[i].consume);
        t[i].Start();
    }

    Thread pt = new Thread(p.produce);
    pt.Start();
}