forked from icterguru/JavaProgrammingA2Z
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathJ18_16.java
More file actions
90 lines (83 loc) · 1.43 KB
/
Copy pathJ18_16.java
File metadata and controls
90 lines (83 loc) · 1.43 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
package chapter18;
/* J18_16.java */
/* A Producer-Consumer Problem */
class Queue // Class Queue
{
int n;
boolean ItemAvailable = false;
synchronized int setItem() // Synchronized Method
{
if(!ItemAvailable)
try
{
wait();
}
catch(Exception E)
{
System.out.println("Exception Caught.");
}
System.out.println("Got Item: "+n);
ItemAvailable = false;
notify();
return n;
}
synchronized void PutItem(int n) // Synchronized Method
{
if(ItemAvailable)
try
{
wait();
}
catch(Exception E)
{
System.out.println("Exception Caught.");
}
this.n = n;
ItemAvailable = false;
System.out.println("Put Item: "+n);
notify();
}
}
class Producer implements Runnable // Thread Producer
{
Queue Q;
Producer(Queue Q)
{
this.Q = Q;
new Thread(this, "Producer").start();
}
public void run()
{
int i = 0;
while(true)
{
Q.PutItem(i++);
}
}
}
class Consumer implements Runnable // Thread Consumer
{
Queue Q;
Consumer(Queue Q)
{
this.Q = Q;
new Thread(this, "Consumer").start();
}
public void run()
{
while(true)
{
Q.setItem();
}
}
}
public class J18_16 // Main Thread
{
public static void main(String args[])
{
Queue Q = new Queue();
new Producer(Q);
new Consumer(Q);
System.out.println("Press Ctrl + C to Stop");
}
}