网站设计 中高端,网络网站,网站备案多少天,wordpress 调用所有1.生产者消费者模式
生产者消费者模式是一个十分经典的多线程协作的模式#xff0c;主要用于解决多线程间的同步问题。它描述了两个类之间的协作#xff1a;生产者和消费者。生产者负责生成数据#xff08;或称为“产品”#xff09;#xff0c;而消费者负责消费这些数据…1.生产者消费者模式
生产者消费者模式是一个十分经典的多线程协作的模式主要用于解决多线程间的同步问题。它描述了两个类之间的协作生产者和消费者。生产者负责生成数据或称为“产品”而消费者负责消费这些数据。这种模式通常用于解决多线程间共享数据的问题
2.代码实现生产者消费者模式
1同步机制
public class Resource {public static Integer tag 0; // 控制哪个线程运行public static Integer count 10; // 模拟某种资源public final static Object lock new Object(); // 锁对象
}2生产者
public class Producer extends Thread{Overridepublic void run(){while(true){synchronized (Resource.lock){if(Resource.count 0){break;}else{if(Resource.tag 1){try {Resource.lock.wait();} catch (InterruptedException e) {System.out.println(e.getMessage());}}else{System.out.println(生产者生产一个产品);Resource.tag 1;Resource.lock.notifyAll();}}}}}
}3消费者
public class Consumer extends Thread{Overridepublic void run(){while(true){synchronized (Resource.lock){if(Resource.count 0){break;}else{if(Resource.tag 0){try {Resource.lock.wait();// 当前线程跟锁进行绑定} catch (InterruptedException e) {System.out.println(e.getMessage());}}else{Resource.count--;System.out.println(消费者消费了一个资源还剩 Resource.count个资源);Resource.lock.notifyAll();Resource.tag 0;}}}}}
}3.利用阻塞队列实现生产者消费者模式
核心生产者和消费者共用一个阻塞队列 1生产者
public class Producer extends Thread{ArrayBlockingQueueString queue;public Producer(ArrayBlockingQueueString queue){this.queue queue;}Overridepublic void run(){while(true){try {queue.put(数据); //生产者生产了一个数据} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}2消费者
public class Consumer extends Thread{ArrayBlockingQueueString queue;public Consumer(ArrayBlockingQueueString queue){this.queue queue;}Overridepublic void run(){while(true){try {String data queue.take();// 消费者消费了一个数据} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}3共用一个阻塞队列
public class Demo {public static void main(String[] args) {ArrayBlockingQueueString queue new ArrayBlockingQueue(2);Producer producer new Producer(queue);producer.setName(生产者);Consumer consumer new Consumer(queue);consumer.setName(消费者);producer.start();consumer.start();
}
