淘先锋技术网

首页 1 2 3 4 5 6 7

java的消费者和生产者模式

Java中的消费者和生产者模式是一种经典的解决多线程并发问题的方案，它主要是用于解决多线程之间对于资源的共享和竞争问题。在多线程环境下，如果多个线程对同一资源进行操作，就容易出现线程安全问题，消费者和生产者模式提供了一种优秀的解决方案。

public class Producer implements Runnable {
private Queue queue;
public Producer(Queue queue) {
this.queue = queue;
}
public void run() {
while (true) {
queue.put(getData());
}
}
private Object getData() {
// 从其他地方获取数据
}
}
public class Consumer implements Runnable {
private Queue queue;
public Consumer(Queue queue) {
this.queue = queue;
}
public void run() {
while (true) {
Object data = queue.take();
processData(data);
}
}
private void processData(Object data) {
// 处理数据
}
}
public class Queue {
private final int MAX_SIZE = 10;
private LinkedListlist = new LinkedList();
public synchronized void put(Object obj) {
while (list.size() == MAX_SIZE) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
list.add(obj);
notifyAll();
}
public synchronized Object take() {
while (list.isEmpty()) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
Object obj = list.removeFirst();
notifyAll();
return obj;
}
}

由上面的代码可以看出，生产者不断往队列中添加数据，而消费者则不断从队列中取出数据进行处理。同时在队列的put和take方法中使用了synchronized关键字修饰方法，确保了这两个方法的原子性操作。而在生产者和消费者线程的run方法中，也不断地循环操作队列。

通过消费者和生产者模式，可以保证多线程环境下对于共享资源的操作都是线程安全的，在线程之间更好的进行协作和通信，提高系统性能，减少不必要的资源浪费。同时，这种模式也可以应用到很多场合中，如消息中间件，多线程爬虫等等。