fork download
copy 
  1. /* package whatever; // don't place package name! */
  2.  
  3. import java.util.ArrayList;
  4. import java.util.List;
  5.  
  6. class Ideone {
  7. 	public static void main(String[] args) {
  8. 		new Ideone();
  9. 	}
  10.  
  11. 	public Ideone() {
  12. 		DummyBuffer<String> buf = new DummyBuffer<String>(new ArrayList<String>(), 5);
  13.  
  14. 		Thread prod = new Thread(new Producer(buf));
  15. 		Thread cons = new Thread(new Consumer(buf));
  16.  
  17. 		prod.run();
  18. 		cons.run();
  19. 	}
  20.  
  21. 	private class Consumer implements Runnable {
  22. 		private DummyBuffer<String> buf;
  23.  
  24. 		public Consumer(DummyBuffer<String> buf) {
  25. 			this.buf = buf;
  26. 		}
  27.  
  28. 		@Override
  29. 		public void run() {
  30. 			buf.take();
  31. 		}
  32. 	}
  33. 	private class Producer implements Runnable {
  34. 		private DummyBuffer<String> buf;
  35.  
  36. 		public Producer(DummyBuffer<String> buf) {
  37. 			this.buf = buf;
  38. 		}
  39.  
  40. 		@Override
  41. 		public void run() {
  42. 			System.out.println("Producer there...");
  43. 			buf.put("Hello World!");
  44. 		}
  45. 	}
  46.  
  47. 	private class DummyBuffer<T> {
  48. 		private final int SIZE;
  49. 		private List<T> data;
  50.  
  51. 		public DummyBuffer(List<T> sharedData, int maxSize) {
  52. 			SIZE = maxSize;
  53. 			data = sharedData;
  54. 		}
  55.  
  56. 		public synchronized T take() {
  57. 			while (data.isEmpty()) {
  58. 				try {
  59. 					System.out.println("waiting... for taking");
  60. 					wait();
  61. 				}
  62. 				catch (InterruptedException e) {
  63. 					// Do nothing
  64. 				}
  65. 			}
  66. 			T item = data.remove(data.size() - 1);
  67.  
  68. 			notifyAll();
  69.  
  70. 			System.out.println("Removed item: " + item);
  71. 			return item;
  72. 		}
  73.  
  74. 		public synchronized void put(T item) {
  75. 			while (data.size() >= SIZE) {
  76. 				try {
  77. 					wait();
  78. 				}
  79. 				catch (InterruptedException e) {
  80. 					// Do nothing
  81. 				}
  82. 			}
  83. 			data.add(item);
  84.  
  85. 			System.out.println("notified");
  86. 			notifyAll();
  87.  
  88. 			System.out.println("Put item: " + item);
  89. 		}
  90. 	}
  91. }
Success #stdin #stdout 0.07s 380160KB
comments (?)
stdin
copy 
Standard input is empty
stdout
copy 
Producer there...
notified
Put item: Hello World!
Removed item: Hello World!
https://ideone.com/fd9OKS
language:
Java (HotSpot 12)
created:
11 years ago
visibility:
public

Share or Embed source code

Discover > Sphere Engine API

The brand new service which powers Ideone!

Discover > IDE Widget

Widget for compiling and running the source code in a web browser!