Thread Producer and Consumer

Question

2.00/5 (1 vote)

See more:

simple console application that maintains a queue of objects. All access to the queue should be handled in a thread-safe manner. At startup, the application should prompt the user for the number of producer and consumer threads to create, defaulting to two of each. The application should then spawn the appropriate number of producer and consumer threads.

Each producer thread should sit in a loop, creating a new object each++ iteration and adding it to the queue. (This does not need to be a tight loop; otherwise the queue could grow too quickly to monitor.)

Each consumer thread should sit in a loop, attempting to remove an object from the queue on each iteration. It should write a line of text to the console each iteration that contains a time stamp, a string representation of the object, an id for the producer thread that created the object, and an id for the consumer thread that displayed the object. If the queue is empty, just a time stamp and "EMPTY" should be written to the console.

The application should run until the user hits the ENTER key. At shutdown, the application should make sure all producer and consumer threads shut down, then display any objects left in the queue, waiting for the user to hit ENTER again before closing.

Posted 24-Mar-12 10:17am

om daga

Updated 24-Mar-12 10:42am

André Kraak

v2

Add a Solution

Comments

Nelek 24-Mar-12 18:22pm

And where are you having problems? This is just the description of the task.

Sergey Alexandrovich Kryukov 24-Mar-12 18:23pm

Not a question.
--SA

om daga 25-Mar-12 8:49am

can you possibel sole this task

Imports System.Threading

Public Class Producer
Private buffer As Buffer
Public value As Integer

Public Sub New(ByVal sharedObject As Buffer)
buffer = sharedObject
Console.WriteLine("Enter Number")
value = Integer.Parse(Console.ReadLine)

End Sub ' New

Public Sub Produce()
Dim count As Integer

For count = 1 To value
Thread.Sleep(4000)
buffer.Buffer = count
Next

Console.WriteLine(Thread.CurrentThread.Name & _
" done producing." & vbCrLf & "Terminating " & _
Thread.CurrentThread.Name & ".")
End Sub

End Class

Public Class Consumer

Private buffer As Buffer

Public Sub New(ByVal sharedObject As Buffer)
buffer = sharedObject
End Sub ' New

Public Sub Consume()
Dim count, sum As Integer

For count = 1 To 10

Thread.Sleep(300)
sum += buffer.Buffer
Next

Console.WriteLine(Thread.CurrentThread.Name & _
" read values totaling: " & sum & "." & vbCrLf & _
"Terminating " & Thread.CurrentThread.Name & ".")
End Sub

End Class

Public Class Buffer
Private mBuffer As Integer = -1
Private occupiedBufferCount As Integer

Public Property Buffer() As Integer
Get
Monitor.Enter(Me)
If occupiedBufferCount = 0 Then
Console.WriteLine("Buffer empty. " & _
Thread.CurrentThread.Name & " waits.")

Monitor.Wait(Me)
End If

occupiedBufferCount -= 1

Console.WriteLine(Thread.CurrentThread.Name & " reads " & _
mBuffer)

Monitor.Pulse(Me)
Dim bufferCopy As Integer = mBuffer

Monitor.Exit(Me)

Return bufferCopy
End Get

Set(ByVal Value As Integer)
Monitor.Enter(Me)

If occupiedBufferCount = 1 Then
Console.WriteLine("Buffer full. " & _
Thread.CurrentThread.Name & " waits.")

Monitor.Wait(Me)
End If

mBuffer = Value

occupiedBufferCount += 1

Console.WriteLine(Thread.CurrentThread.Name & " writes " & _
mBuffer)

Monitor.Pulse(Me)
Monitor.Exit(Me)
End Set

End Property ' Buffer

End Class
Module Tester
Sub Main()
Dim holdInteger As New Buffer()
Dim producer As New Producer(holdInteger)
Dim consumer As New Consumer(holdInteger)

Dim producerThread As New Thread(AddressOf producer.Produce)
Dim consumerThread As New Thread(AddressOf consumer.Consume)

producerThread.Name = "Producer"
consumerThread.Name = "Consumer"

producerThread.Start()
consumerThread.Start()
End Sub

End Module

1 solution

Add a Solution

Add your solution here

Treat my content as plain text, not as HTML

Preview 0

…

Existing Members

Sign in to your account

...or Join us

Download, Vote, Comment, Publish.

Your Email
Password
Forgot your password?

Your Email
This email is in use. Do you need your password?
Optional Password

I have read and agree to the Terms of Service and Privacy Policy
Please subscribe me to the CodeProject newsletters

When answering a question please:

Read the question carefully.
Understand that English isn't everyone's first language so be lenient of bad spelling and grammar.
If a question is poorly phrased then either ask for clarification, ignore it, or edit the question and fix the problem. Insults are not welcome.
Don't tell someone to read the manual. Chances are they have and don't get it. Provide an answer or move on to the next question.

Let's work to help developers, not make them feel stupid.

This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)

André Kraak · Answer 1 · 2012-03-24T10:45:00

This looks like homework.

It would be best if you did your own homework. It is given to you so that you will learn something, think about what have been taught. Read your text books and give it a try.
Have a look at this wiki: Producer-consumer problem[^]

Once you have code and run into problems you can always come back here with a more specific question and the community will do its best to help you. Don't forget to post only the relevant code bits that pose the problem as a code dump is not usually helpful at all in getting someone to help/assist you.