Java 多线程 简单实例 （消费者与生成者）的关系
2024-04-05 21:40:02
PS::线程这套东西在PHP里完全是不存在的概念，有待进一步的学习；
PS::这个实例是根据书本上的知识进行扩展的，理解程度50%左右吧！
1.定义生产消费环境
package second;
public class Queue {
int value = ;
boolean isEmpty = true;
/**
* 生产者
* @param v
*/
public synchronized void put(int v){
if(!isEmpty){//如果存在数据没有被消费
try{
System.out.println("生产者等待...");
wait();
}catch(Exception e){
}
}
value ++;//本次生产1个
isEmpty = false;//设置为false(代表有东西了可以消费了)
System.out.println("生产者共生产数量:" + v);
notify();//通知消费者开始消费
}
public synchronized int get(){
//如果消费数据没有了，消费者继续等...
if(isEmpty){
try{
System.out.println("消费者等待...");
wait();
}catch(Exception e){
}
}
value --;
if(value < ){
isEmpty = true;//如果消费完了，则设置为true
}
System.out.println("消费者消费一个，剩余："+value);
notify();
return value;
}
}
2.生产者
package second;
public class Producer extends Thread {
Queue q;
Producer(Queue q){
this.q = q;
}
public void run(){
for(int i=;i<;i++){//循环生产5次
q.put(i);
}
}
}
3.消费者
package second;
public class Consumer extends Thread {
Queue q;
Consumer(Queue q){
this.q = q;
}
public void run(){
while(true){//永远的消费下去,直到不再生产为止
q.get();
}
}
}
4.线程调用
package second;
public class Cao {
public static void main(String[] args){
Queue q = new Queue();//实例消费&生成工厂
Producer p = new Producer(q);//将工厂传入给生产者
Consumer c = new Consumer(q);//将工厂传入给消费者
p.start();//开启生成线程
c.start();//开启消费线程
}
}
最新文章
- EXT总结例子
- nginx1.8安装nginx_concat_module及400错误解决办法
- FM四舍五入_从小数点最后一位进位
- android 6.0 SDK中删除HttpClient的相关类的解决方法
- SPAdes
- 【Andorid开发框架学习】之Mina开发之服务器开发
- Spark Streaming揭秘 Day18 空RDD判断及程序中止机制
- 解决mybatis查询返回结果值串查
- My97DatePicker{js日历插件}
- Apache Spark 2.2.0 中文文档 - Spark Streaming 编程指南 | ApacheCN
- CodeForces - 556A Case of the Zeros and Ones
- js基础进阶--编的实用技巧(一)
- C++ STL容器总结
- Handler基本运行机制
- Android 经典欧美小游戏 guess who
- Python 函数修饰符（装饰器）的使用
- web计时机制
- Java从零开始学三十五(JAVA IO- 字节流)
- My deep learning reading list
- Android Studio 编写 JNI