一个java生产者消费者代码的问题

0 0

一个java生产者消费者代码的问题5

一个生产者消费者的代码,使用lock和condition实现。

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(&quot;Apple produced.&quot;);


available = true;


consumed.signal(); // 发信号唤醒等待这个Condition的线程

} finally {

lock.unlock();

}

}


public void consume() throws InterruptedException {

lock.lock();


try {

if (!available) {

consumed.await(); // 放弃lock进入睡眠

}


/* 吃苹果 */

System.out.println(&quot;Apple consumed.&quot;);


available = false;


produced.signal(); // 发信号唤醒等待这个Condition的线程

} finally {

lock.unlock();

}

}

}

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();
	}
}

以上代码我觉的执行结果应该是一个Apple prodeced 跟着一个App consumed, 就是说如果生产一个苹果，那么它应该立即被消费掉，但是实际的执行结果却不一定，有时候的执行结果为:

Apple produced.
Apple consumed.
Apple produced.
Apple produced.
Apple consumed.
Apple consumed.
Apple produced.
Apple consumed.

出现了连续生产两次苹果，我想问问大牛们是这是什么原因啊?

2013年6月24日 21:20

jingtao416
21
0 0 3

6个答案按时间排序按投票排序

0 0

采纳的答案

跟406657836 说的类似，但还是不完全一样；
答案及解决方案在：
http://jinnianshilongnian.iteye.com/blog/1893690

2013年6月25日 07:36

jinnianshilongnian
7280
2 3 591

4条评论

0 0

更正，我的卡死的说法是错误的，楼主的代码不会导致卡死。

2013年6月25日 10:19

teasp
76
0 0 8

添加评论

0 0

除了if (!available)这种错误用法外，楼主的代码有个更严重的问题：会卡死。因为很可能出现两个producer或者两个consumer同时wait的情况。只用consumer和producer线程都只有一个的情况下才不会卡死。

2013年6月25日 08:56

teasp
76
0 0 8

添加评论

0 0

if (!available) 问题应该在这里，这种用法是错误的，把if改成while。

2013年6月25日 08:28

teasp
76
0 0 8

3条评论

0 0

关于这类问题，我在csdn上有篇博客。是一道阿里巴巴的面试题，和你这个是一个类型的题目。你可以去看下。
http://blog.csdn.net/liguogangde/article/details/9103501
发生问题的原理是一样的。就不重复叙述了呵！

2013年6月25日 00:44

406657836
46
0 0 3

2条评论

0 0

boolean available = false; 加个volatile试一下,应该是值变了但线程的工作内存没检测到值的变化

2013年6月25日 00:44

anglestudio
10
0 1 6

3条评论

已解决问题

未解决问题

排行榜

查看全部排名>>