fork(1) download 
  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. 		cons.run();
  18. 		prod.run();
  19.  
  20. 	}
  21.  
  22. 	private class Consumer implements Runnable {
  23. 		private DummyBuffer<String> buf;
  24.  
  25. 		public Consumer(DummyBuffer<String> buf) {
  26. 			this.buf = buf;
  27. 		}
  28.  
  29. 		@Override
  30. 		public void run() {
  31. 			buf.take();
  32. 		}
  33. 	}
  34. 	private class Producer implements Runnable {
  35. 		private DummyBuffer<String> buf;
  36.  
  37. 		public Producer(DummyBuffer<String> buf) {
  38. 			this.buf = buf;
  39. 		}
  40.  
  41. 		@Override
  42. 		public void run() {
  43. 			System.out.println("Producer there...");
  44. 			buf.put("Hello World!");
  45. 		}
  46. 	}
  47.  
  48. 	private class DummyBuffer<T> {
  49. 		private final int SIZE;
  50. 		private List<T> data;
  51.  
  52. 		public DummyBuffer(List<T> sharedData, int maxSize) {
  53. 			SIZE = maxSize;
  54. 			data = sharedData;
  55. 		}
  56.  
  57. 		public synchronized T take() {
  58. 			while (data.isEmpty()) {
  59. 				try {
  60. 					System.out.println("waiting... for taking");
  61. 					wait();
  62. 				}
  63. 				catch (InterruptedException e) {
  64. 					// Do nothing
  65. 				}
  66. 			}
  67. 			T item = data.remove(data.size() - 1);
  68.  
  69. 			notifyAll();
  70.  
  71. 			System.out.println("Removed item: " + item);
  72. 			return item;
  73. 		}
  74.  
  75. 		public synchronized void put(T item) {
  76. 			while (data.size() >= SIZE) {
  77. 				try {
  78. 					wait();
  79. 				}
  80. 				catch (InterruptedException e) {
  81. 					// Do nothing
  82. 				}
  83. 			}
  84. 			data.add(item);
  85.  
  86. 			System.out.println("notified");
  87. 			notifyAll();
  88.  
  89. 			System.out.println("Put item: " + item);
  90. 		}
  91. 	}
  92. }
Time limit exceeded #stdin #stdout 5s 380224KB
comments (?)
stdin 
Standard input is empty
stdout 
waiting... for taking
https://ideone.com/FoTSBW
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!