开发工具:
文件大小: 3kb
下载次数: 0
上传时间: 2009-02-09
详细说明： package producer; import java.util.Vector;//输入java矢量 class SyncStack {//实现堆栈功能，不能同时读写 private Vector buffer//私人接口向量缓冲区 = new Vector //新建向量 (400,200); char contents; private boolean ava=false; public synchronized char get() {//出栈 while (ava==false) //如果生产者还没有产生字符就一直等待 { try { this.wait(); } catch (InterruptedException e)//当线程在活动之前或活动期间处于正在等待、休眠或占用状态且该线程被中断时，抛出该异常 { e. printStackTrace(); } } ava=false; notifyAll(); return contents; } public synchronized void push(char c) { while(ava==true){ try { wait(); } ca tch (InterruptedException e) { // TODO 自动生成 catch 块 e.printStackTrace(); } }//入栈 ava=true; this.notify();//通知其它线程把数据出栈 Character charObj = new Character(c); buffer.addElement(charObj); contents=c; } public void print(char c) { // TODO 自动生成方法存根 } } class ControlEnter {//每行输出结果的个数 public static int count = 0; void counter() { count++; if(count ==5) { System.out.println(); count = 0; } } } class Producer implements Runnable {//生产者类 private SyncStack theStack;//生产者类获得的字符都来自同步堆栈 private ControlEnter controlenter; public Producer (SyncStack s,ControlEnter ce) { theStack = s; controlenter = ce; } public void run() { char c; for (int i = 0; i < 30; i++) { c = (char)(Math.random() * 26 + 'a');//随机产生30个小写字母 theStack.push(c);//存入堆栈 System.out.print("生产者产生: " + c +" "); controlenter.counter( ); try { Thread.sleep//线程休眠 ((int)(Math.random() * 200));//以0~200ms的速度随机 } catch (InterruptedException e) //当线程在活动之前或活动期间处于正在等待、休眠或占用状态且该线程被中断时，抛出该异常 { e.printStackTrace( ); } } } } class Consumer implements Runnable {//消费者类 private SyncStack theStack;//消费者类获得的字符都来自同步堆栈 private ControlEnter controlenter; public Consumer (SyncStack s,ControlEnter ce) { theStack = s; controlenter = ce; } public void run() { char value; for (int i=0; i < 30; i++) {//从堆栈中取数，并输出 value = theStack.get();//取出生产者产生的字母 System.out.print("消费者消费: " + value+" ");//消费者输出 controlenter.counter( ); try { Thread.sleep((int) (Math.random() * 2000));//控制取数的速度：0～2s/*每读取一个字符线程就睡眠*/ } catch (InterruptedException e)//当线程在活动之前或活动期间处于正在等待、休眠或占用状态且该线程被中断时，抛出该异常 { e.printStackTrace(); } } } } public class B {//主线程总调度 public static void main(String []args) { ControlEnter ce = new ControlEnter(); SyncStack stack = new SyncStack();//下面的消费者类对象和生产者类对象所操作的是同一个同步堆栈对象 Producer p1 = new Producer(stack,ce); new Thread(p1).start();//生产者线程启动 Consumer c1 = new Consumer(stack,ce); new Thread(c1).start();//消费者线程启动 } } ...展开收缩
(系统自动生成,下载前可以参看下载内容)
下载文件列表
相关说明
- 本站资源为会员上传分享交流与学习,如有侵犯您的权益,请联系我们删除.
- 本站是交换下载平台，提供交流渠道，下载内容来自于网络，除下载问题外，其它问题请自行百度。
- 本站已设置防盗链，请勿用迅雷、QQ旋风等多线程下载软件下载资源，下载后用WinRAR最新版进行解压.
- 如果您发现内容无法下载，请稍后再次尝试；或者到消费记录里找到下载记录反馈给我们.
- 下载后发现下载的内容跟说明不相乎，请到消费记录里找到下载记录反馈给我们，经确认后退回积分.
- 如下载前有疑问，可以通过点击"提供者"的名字，查看对方的联系方式，联系对方咨询.
