一个生产者消费者的代码,使用lock和condition实现。
[code="java"]
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
//生产/消费者模式
public class Basket {
Lock lock = new ReentrantLock();
// 产生Condition对象
Condition produced = lock.newCondition();
Condition consumed = lock.newCondition();
boolean available = false;
public void produce() throws InterruptedException {
lock.lock();
try {
if (available) {
produced.await(); // 放弃lock进入睡眠
}
System.out.println("Apple produced.");
available = true;
consumed.signal(); // 发信号唤醒等待这个Condition的线程
} finally {
lock.unlock();
}
}
public void consume() throws InterruptedException {
lock.lock();
try {
if (!available) {
consumed.await(); // 放弃lock进入睡眠
}
/* 吃苹果 */
System.out.println("Apple consumed.");
available = false;
produced.signal(); // 发信号唤醒等待这个Condition的线程
} finally {
lock.unlock();
}
}
}
[/code]
[code="java"]
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
//测试用类
public class ConditionTester {
public static void main(String[] args) throws InterruptedException {
final Basket basket = new Basket();
// 定义一个producer
Runnable producer = new Runnable() {
public void run() {
try {
basket.produce();
} catch (InterruptedException ex) {
ex.printStackTrace();
}
}
};
// 定义一个consumer
Runnable consumer = new Runnable() {
public void run() {
try {
basket.consume();
} catch (InterruptedException ex) {
ex.printStackTrace();
}
}
};
// 各产生10个consumer和producer
ExecutorService service = Executors.newCachedThreadPool();
for (int i = 0; i < 4; i++)
service.submit(consumer);
Thread.sleep(2000*2);
for (int i = 0; i < 4; i++)
service.submit(producer);
service.shutdown();
}
}
[/code]
以上代码我觉的执行结果应该是一个Apple prodeced 跟着一个App consumed, 就是说如果生产一个苹果，那么它应该立即被消费掉，但是实际的执行结果却不一定，有时候的执行结果为:
[code="java"]
Apple produced.
Apple consumed.
Apple produced.
Apple produced.
Apple consumed.
Apple consumed.
Apple produced.
Apple consumed.
[/code]
出现了连续生产两次苹果，我想问问大牛们是这是什么原因啊?
跟406657836 说的类似，但还是不完全一样；
答案及解决方案在：
[url]http://jinnianshilongnian.iteye.com/blog/1893690[/url]
boolean available = false; 加个volatile试一下,应该是值变了但线程的工作内存没检测到值的变化
关于这类问题，我在csdn上有篇博客。是一道阿里巴巴的面试题，和你这个是一个类型的题目。你可以去看下。
http://blog.csdn.net/liguogangde/article/details/9103501
发生问题的原理是一样的。就不重复叙述了呵！
if (!available) 问题应该在这里，这种用法是错误的，把if改成while。
除了if (!available)这种错误用法外，楼主的代码有个更严重的问题：会卡死。因为很可能出现两个producer或者两个consumer同时wait的情况。只用consumer和producer线程都只有一个的情况下才不会卡死。
更正，我的卡死的说法是错误的，楼主的代码不会导致卡死。