Java实现生产者与消费者问题

1697阅读　0评论2011-05-13　高傲的活着
分类：Java

  1. public class ProducerConsumer {
  3. public static void main(String[] args) {
  5. SyncStack ss = new SyncStack();
  7. Producer p = new Producer(ss);
  9. Consumer c = new Consumer(ss);
  11. new Thread(p).start();
  13. new Thread(p).start();
  15. new Thread(p).start();
  17. new Thread(c).start();
  19. }
  21. }
  25. class WoTou {
  27. int id;
  31. WoTou(int id) {
  33. this.id = id;
  35. }
  39. public String toString() {
  41. return "WoTou : " + id;
  43. }
  45. }
  49. class SyncStack {
  51. int index = 0;
  55. WoTou[] arrWT = new WoTou[6];
  59. public synchronized void push(WoTou wt) {
  61. while (index == arrWT.length) {
  63. try {
  65. this.wait();
  67. } catch (InterruptedException e) {
  69. e.printStackTrace();
  71. }
  73. }
  75. this.notifyAll();
  77. arrWT[index] = wt;
  79. index++;
  81. }
  85. public synchronized WoTou pop() {
  87. while (index == 0) {
  89. try {
  91. this.wait();
  93. } catch (InterruptedException e) {
  95. e.printStackTrace();
  97. }
  99. }
  101. this.notifyAll();
  103. index--;
  105. return arrWT[index];
  107. }
  109. }
  113. class Producer implements Runnable {
  115. SyncStack ss = null;
  119. Producer(SyncStack ss) {
  121. this.ss = ss;
  123. }
  127. public void run() {
  129. for (int i = 0; i < 20; i++) {
  131. WoTou wt = new WoTou(i);
  133. ss.push(wt);
  135. System.out.println("生产了：" + wt);
  137. try {
  139. Thread.sleep((int) (Math.random() * 200));
  141. } catch (InterruptedException e) {
  143. e.printStackTrace();
  145. }
  147. }
  149. }
  151. }
  155. class Consumer implements Runnable {
  157. SyncStack ss = null;
  161. Consumer(SyncStack ss) {
  163. this.ss = ss;
  165. }
  169. public void run() {
  171. for (int i = 0; i < 20; i++) {
  173. WoTou wt = ss.pop();
  175. System.out.println("消费了: " + wt);
  177. try {
  179. Thread.sleep((int) (Math.random() * 1000));
  181. } catch (InterruptedException e) {
  183. e.printStackTrace();
  185. }
  187. }
  189. }
  191. }

 threadDemo.zip   

转自：http://hi.baidu.com/greatwqs/blog/item/744fa65936dec1d49c820480.html

上一篇：JAVAEYE:JAVA面试题解惑系列列表.
下一篇：Flex项目之聊天表情