JUC-Condition线程通信

Posted 美好的明天

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了JUC-Condition线程通信相关的知识,希望对你有一定的参考价值。

1,Codition接口描述了可能会与锁有关联的条件变量。这些变量在用法上与使用Object.wait访问的隐式监视器类似。

但提供了更强大的功能,需要指出的是,单个lock可能与多个condition对象关联。为了避免兼容性问题,condition方法的名称与对应的object版本中不一样。

2,在condition对象中,与wait,notify,notifyAll方法对应的分别是await,signal,和signalAll。

3,condition实例实质上是被绑定到了一个锁上,要为特定Lock实例获得condition实例,请使用newCondition()方法。

 

针对上一节中使用synchronized和wait方法处理的生产者与消费者程序中,这里通过Lock和condition来联合处理。

要实现Lock和Condition处理,必须先实力化两个对象。

实例化Lock对象:

private Lock lock = new ReentrantLock();

实例化Condition对象:通过Lock对象的newCondition方法实例化,来获得Lock的锁,从而实现与Lock锁通信,进行唤醒,等待操作

private Condition condition = lock.newCondition();

代码:

注意:await方法上一节的wait方法一致,需要放到while循环里面,避免被唤醒后条件不满足也继续执行。

package com.atguigu.juc;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/*
 * 生产者消费者案例:
 */
public class TestProductorAndConsumerForLock {

    public static void main(String[] args) {
        Clerk clerk = new Clerk();

        Productor pro = new Productor(clerk);
        Consumer con = new Consumer(clerk);

        new Thread(pro, "生产者 A").start();
        new Thread(con, "消费者 B").start();

         new Thread(pro, "生产者 C").start();
         new Thread(con, "消费者 D").start();
    }
}

class Clerk {
    private int product = 0;

    private Lock lock = new ReentrantLock();
    private Condition condition = lock.newCondition();

    // 进货
    public void get() {
lock.lock();
try { while (product >= 1) { // 为了避免虚假唤醒,应该总是使用在循环中。 System.out.println("产品已满!"); try { condition.await(); } catch (InterruptedException e) { } } System.out.println(Thread.currentThread().getName() + " : " + ++product); condition.signalAll(); } finally { lock.unlock(); } } // 卖货 public void sale() { lock.lock(); try { while (product <= 0) { System.out.println("缺货!"); try { condition.await(); } catch (InterruptedException e) { } } System.out.println(Thread.currentThread().getName() + " : " + --product); condition.signalAll(); } finally { lock.unlock(); } } } // 生产者 class Productor implements Runnable { private Clerk clerk; public Productor(Clerk clerk) { this.clerk = clerk; } @Override public void run() { for (int i = 0; i < 20; i++) { try { Thread.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); } clerk.get(); } } } // 消费者 class Consumer implements Runnable { private Clerk clerk; public Consumer(Clerk clerk) { this.clerk = clerk; } @Override public void run() { for (int i = 0; i < 20; i++) { clerk.sale(); } } }

执行结果:

正常执行

 

以上是关于JUC-Condition线程通信的主要内容,如果未能解决你的问题,请参考以下文章

多个用户访问同一段代码

多个请求是多线程吗

Motan在服务provider端用于处理request的线程池

在tablayout片段之间进行通信[重复]

与另一个片段通信的片段接口

无法通过接口获取与片段通信的活动