Chinaunix首页 | 论坛 | 博客

一只有理想的蜗牛youxia.blog.chinaunix.net

首页　| 　博文目录　| 　关于我

高傲的活着

  • 博客访问： 2244453
  • 博文数量： 556
  • 博客积分： 11457
  • 博客等级： 上将
  • 技术积分： 5973
  • 用 户 组： 普通用户
  • 注册时间： 2011-02-24 22:33
文章分类

全部博文（556）

文章存档

2013年（22）

2012年（74）

2011年（460）

我的朋友
最近访客
推荐博文
相关博文
Java实现生产者与消费者问题

分类： Java

2011-05-13 12:15:05

  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

阅读(1651) | 评论(0) | 转发(0) |
0

上一篇：JAVAEYE:JAVA面试题解惑系列列表.

下一篇：Flex项目之聊天表情

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6