Question: 1. List the processes (threads) running when you run the application 2. Which one of them are sharing information? 3. What kind of sharing mechanism
1. List the processes (threads) running when you run the application 2. Which one of them are sharing information? 3. What kind of sharing mechanism is being used and how?
import java.util.Date;
import java.lang.*;
public class Factory
{
public static void main(String args[])
{
// creates the message queue
Channel queue = new Channel();
// Creates the producer and consumer threads and pass
Thread producer = new Thread(new Producer(queue));
Thread consumer = new Thread(new Consumer(queue));
// start the threads
producer.start();
consumer.start();
}
}
class Channel {
private Date date;
public void send(Date message){
this.date = message;
}
public Date receive() {
return date;
}
}
class Producer implements Runnable
{
private Channel queue;
public Producer(Channel queue)
{
this.queue = queue;
}
public void run()
{
try
{
Date message;
while (true)
{
// nap for awhile
Thread.sleep(10);
// produces an item and enter it into the buffer
message = new Date();
System.out.println("Producer produced " + message);
queue.send(message);
}
}
catch (InterruptedException e) {
System.out.println("I was interrupted!");
}
}
}
class Consumer implements Runnable{
private Channel queue;
public Consumer(Channel queue)
{
this.queue = queue;
}
public void run()
{
try
{
Date message;
while(true)
{
// nap for awhile
Thread.sleep(10);
// consumes an item from the buffer
message = queue.receive();
if (message != null)
System.out.println("Consumer consumed " + message);
}
}
catch (InterruptedException e) {
System.out.println("I was interrupted!");
}
}
}
Step by Step Solution
There are 3 Steps involved in it
Get step-by-step solutions from verified subject matter experts
