Java-ICT312T/ProducerConsumer.java at master · ola-nishant/Java-ICT312T · GitHub

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
91
92
// import java.util.LinkedList;
// import java.util.Queue;

// class Buffer{
//     private Queue<Integer> items = new LinkedList<Integer>();
//     private int capacity;
//     public Buffer(int capacity){
//         this.capacity = capacity;
//     }
//     public synchronized void produce(int item){
//         while(items.size() == capacity){
//             try{
//                 System.out.println("buffer full, producer waiting");
//                 wait();
//             }
//             catch(InterruptedException e){
//                 e.printStackTrace();
//             }
//         }
//         items.add(item);
//         System.out.println("item added: "+item);
//         notify();
//     }
//     public synchronized int consume(){
//         while(items.size() == 0){
//             try{
//                 System.out.println("buffer empty");
//                 wait();
//             }
//             catch (InterruptedException e){
//                 e.printStackTrace();
//             }
//         }
//         int item = items.remove();
//         System.out.println("item removed: "+item);
//         notify();
//         return item;
//     }
// }
// class Producer extends Thread{
//     private Buffer buffer;
//     Producer(Buffer buffer){
//         this.buffer = buffer;
//     }
//     public void run(){
//         for(int i = 0; i < 10; i++){
//             buffer.produce(i);
//             try{
//                 Thread.sleep((long)(Math.random()*1000));
//             }
//             catch(InterruptedException e){
//                 e.printStackTrace();
//             }
//         }
//     }
// }
// class Consumer extends Thread{
//     private Buffer buffer;
//     Consumer(Buffer buffer){
//         this.buffer = buffer;
//     }
//     public void run(){
//         for(int i = 0; i < 10; i++){
//             buffer.consume();
//             try{
//                 Thread.sleep((long)(Math.random()*1000));
//             }
//             catch(InterruptedException e){
//                 e.printStackTrace();
//             }
//         }
//     }
// }
// public class ProducerConsumer {
//     public static void main(String[] args){
//         Buffer buffer = new Buffer(3);
//         Producer producer = new Producer(buffer);
//         Consumer consumer = new Consumer(buffer);
//         producer.start();
//         consumer.start();
//     }
// }


import java.util.Queue;
import java.util.LinkedList;
class Buffer{
    private Queue<Integer> items = new LinkedList<Integer>();
    private int capacity;

}