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

一个生产者消费者的代码,使用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]

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

jingtao416
jingtao416 谢谢大家的回复,teasp提出的把if改成while确实正确,还有406657836的回答给我了很好的提示,但好像只有一个采纳答案,给了jinnianshilongnian ,谢谢jinnianshilongnian 的耐心又详细的回答,再次感谢大家
7 年多之前 回复

6个回答

跟406657836 说的类似,但还是不完全一样;
答案及解决方案在:
[url]http://jinnianshilongnian.iteye.com/blog/1893690[/url]

teasp
teasp 你的代码解决了楼主代码中的一个严重问题,但是没有解决连续打印两个相同结果的问题。
7 年多之前 回复
jinnianshilongnian
jinnianshilongnian 怎么说?
7 年多之前 回复
teasp
teasp 不对,我又仔细看了下,你的解释是错误的。
7 年多之前 回复
teasp
teasp 你的解释是对的。
7 年多之前 回复

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

jingtao416
jingtao416 volatile这个我试了,没有作用
7 年多之前 回复
teasp
teasp 没必要volatile。
7 年多之前 回复
liguogangde
李国刚 这个变量在ReentrantLock包围的区域,是不能重排序的,是具有可见性的!这个问题可以参见下http://blog.csdn.net/liguogangde/article/details/9103501一道阿里的面试题
7 年多之前 回复

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

teasp
teasp 修正一下,链接里面的说法不是错的。
7 年多之前 回复
teasp
teasp 你链接里面的说法是错误的。
7 年多之前 回复

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

teasp
teasp 咱们到http://jinnianshilongnian.iteye.com/blog/1893690个里面讨论吧
7 年多之前 回复
liguogangde
李国刚 你能分析下卡死的问题吗?他的available是在不断的切换的,我没有看出哪里会卡死呀!
7 年多之前 回复
liguogangde
李国刚 嗯 变成while也可以 或者 双重判断,即在打印之前再判断!
7 年多之前 回复

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

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

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问
相关内容推荐