- 浏览: 570405 次
- 性别:
- 来自: 苏州
文章分类
- 全部博客 (206)
- Flask (1)
- JavaScript (3)
- Core Java (41)
- XML (1)
- Oracle (11)
- 软件安装及环境配置 (0)
- 其它 (9)
- 面试/笔试 (5)
- 项目 (0)
- JDBC (11)
- Servlet (4)
- MySql (4)
- JNDI (0)
- Hibernate (11)
- Java模式和构架设计 (0)
- Web设计 (22)
- JSP (8)
- Struts (13)
- Tomcat (2)
- Marven (2)
- SVN (2)
- Swing/AWT (1)
- jQuery (2)
- ExtJS (8)
- Python (22)
- Flex (1)
- Django (7)
- 算法 (5)
- English (1)
- Twisted (1)
- Linux (3)
- Rails (1)
- SVG (3)
- PostgreSQL (1)
- wait()和notify()¬ifyAll()必须工作在加锁(synchronized)的代码块中。
- 抢占的锁和释放的锁要是同一对象的锁,否则抛出IllegalMonitorStateException。
Stack.java
package thread; public class Stack { private Object[] objs; private int index = 0; public Stack() { this(3); } public Stack(int length) { this.objs = new Object[length]; } public void push(Object obj) { synchronized (this) { while (index == this.objs.length) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } for (int i = 0; i < 100000; i++) {}; objs[index] = obj; index++; this.notifyAll(); } } public Object pop() { synchronized (this) { while (index == 0) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } --index; for (int i = 0; i < 100000; i++) {}; Object value = this.objs[index]; this.notifyAll(); return value; } } }
Producer.java
package thread; import java.util.Random; public class Producer extends Thread{ private Stack stack; public Producer(Stack stack){ this.stack = stack; } @Override public void run() { Random ran = new Random(); for (int i = 0; i < 20; i++) { Object obj = ran.nextInt(200); stack.push(obj); System.out.println(obj+" 压入成功。" ); try { Thread.sleep(300); } catch (InterruptedException e) { e.printStackTrace(); } } } }
Customer.java
package thread; public class Customer extends Thread{ private Stack stack; public Customer(Stack stack) { this.stack = stack; } @Override public void run() { for (int i = 0; i < 20; i++) { Object value = stack.pop(); System.out.println(value+" 弹出成功。"); try { Thread.sleep(300); } catch (InterruptedException e) { e.printStackTrace(); } } } }
Test.java
package thread; public class Test { public static void main(String[] args) { Stack stack = new Stack(); for (int i = 0; i < 20; i++) { Producer p = new Producer(stack); p.setName("producerThread"); p.start(); } for (int i = 0; i < 20; i++) { Customer c = new Customer(stack); c.setName("customerThread"); c.start(); } } }
发表评论
-
线程的停止
2010-12-24 00:30 1105既然stop()是不被推荐的 ... -
JDK环境变量的配置
2010-12-19 11:03 932JDK环境变量的配置 (1)JAVA_HOME C:\Pro ... -
自定义异常
2010-12-10 12:09 1158内置异常不可能始终足以捕获所有错误,因此需要用户自定义的异常类 ... -
编写异常的规范
2010-12-10 11:35 1126错误的编码: OutputStreamWriter out ... -
内部类
2010-12-06 16:51 1093内部类详解 1、定义 一个类的定义放在另一个类的内部,这个 ... -
抽象类和接口的区别
2010-12-06 16:47 1025含有abstract修饰符的class 即为抽象类,abstr ... -
人工抛出异常
2010-12-06 16:35 2054Java异常类对象除在程序执行过程中出现异常时由系统自动生成并 ... -
Java异常处理机制
2010-12-06 16:30 10141.Java程序的执行过程中如出现异常,会自动生成一个异常类对 ... -
Java的垃圾回收原理与机制
2010-12-06 16:12 1116JAVA中的对象是在堆上分配,而在堆上分配存储空间的方式是昂贵 ... -
Comparable和Comparator接口
2010-12-06 15:13 1663当需要排序的集合或数组不是单纯的数字型时,通常可以使用Comp ... -
手工打包JAR
2010-12-06 12:57 21951.把准备打包的.java文件集中到一个目录中例如c:\sou ... -
Java集合类
2010-12-03 14:26 1257Collection接口 Collection是 ... -
Java Socket 初步详解
2010-11-08 09:05 1027网络编程的基本模型就 ... -
Java中newString(abc)创建几个对象的解释
2010-11-02 10:04 1846String str=new String("abc ... -
Java日期处理
2010-10-19 17:17 13701.有关日期时间的类 1.java.util.Date ... -
线程同步
2010-10-17 21:17 1044一个方法被synchronized修饰:当程序执行此方法时,当 ... -
线程的状态及生命周期
2010-10-17 20:29 1466线程共有6种状态;在某一时刻只能是这6种状态之一。这些状态由T ... -
sleep()、wait()、yield()、join()方法 浅析
2010-10-17 18:54 1057线程退出最好自己实现,在运行状态中一直检验一个状态,如果这 ... -
RandomAccessFile类的应用
2010-10-17 10:39 1724文件存取通常是顺序的,每在文件中存取一次,文件的读 ... -
利用Externalizable接口实现对象的自定义序列化
2010-10-17 10:12 1263SerializedUser.java import jav ...
相关推荐
用c语言 pv操作解决生产者与消费者问题
生产者与消费者问题(操作系统)
C#编写的有关操作系统中生产者与消费者问题的实例,画面美观,生动形象的描绘了生产者与消费者之间的关系,代码部分简介易懂。
进程同步实验——生产者与消费者问题算法实现
大连理工大学操作系统大作业, 进程同步与互斥 生产者与消费者问题
该程序是我写的博客“一起talk C栗子吧(第一百零六回:C语言实例--生产者与消费者问题二)”的配套程序,共享给大家使用
上课实验用VC++做的操作系统实验之进程的互斥与同步(生产者与消费者问题),内含实验报告,希望对大家有帮助
“生产者---消费者”问题是最著名的进程同步问题。它描述了一组生产者向一组消费者提供产品,它们共享一个有界缓冲区,生产者向其中投放产品,消费者从中取得产品。它是许多相互合作进程的抽象,如输入进程与计算...
大连理工大学软件学院操作系统实验 生产者与消费者问题代码 热乎出炉 复制粘贴即能运行 !
操作系统概念第七版第七单元实验 生产者与消费者问题linux下pthread代码 注释:此为刚完成的代码 请下载者主动修改 谢谢---mayy
用C++实现了计算机操作系统中的生产者与消费者问题。
利用Java多线程实现的操作系统的生产者与消费者算法,主要用到了线程的同步,等待与唤醒操作。
生产者与消费者问题 java #include #include const unsigned short SIZE_OF_BUFFER = 10; //缓冲区长度 unsigned short ProductID = 0; //产品号 unsigned short ConsumeID = 0; //将被消耗的产品号 unsigned ...
C++版生产者与消费者问题,这是经过我自己编译过的,没有问题,希望大家喜欢
本文通过多线程方法解决了生产者与消费者之间同步的问题