(七)java多线程之Condition

引言

在写(五)java多线程之Lock类时,我们暂时忽略掉Lock的一个方法,那就是Lock.newCondition(),这个方法返回一个Condition,现在我们这章就重点讲这个东东是什么,以及怎么使用.

理论

Condition的中文翻译是状态.没错,这个就是让多线程在不同状态切换其他线程执行.跟Object.wait和Object.notify有点类似.

Condition.await: 让当前线程一直等到直到获取信号,或者发生中断.通过和lock锁互相配合,会使当前线程一直睡眠直到一下四种情况的其中一种发生:

另外一个线程调用当前Condition的signal方法,这当前线程会被挑选出来,并被唤醒

其他线程调用了当前Condition的signalAll方法

其他线程调用了当前线程的中断,这当前中断会被挂起

当前线程被假唤醒

Condition.awaitUninterruptibly 跟Condition.await类似,只是不能被中断

Condition.await(long time, TimeUnit unit) 当前线程会被唤醒,要么是获得信号,要么是中断,要么是指定时间到

Condition.awaitUntil(Date deadline)当前线程会被唤醒,要么是获得信号,要么是中断,要么是到了指定结束时间

一般用法如下

java

>boolean aMethod(Date deadline) {

> boolean stillWaiting = true;

> lock.lock();

> try {

> while (!conditionBeingWaitedFor()) {

> if (!stillWaiting)

> return false;

> stillWaiting = theCondition.awaitUntil(deadline);

> }

> // ...

> } finally {

> lock.unlock();

> }

>}

>

Condition.signal 唤醒等待的线程.如果当前的condition有多个线程在等待的话,这会唤醒其中一,且这个线程在返回await前必须重新获得锁

‘Condition.signalAll’ 唤醒所有等待的线程.如果当前的condition有多个线程在等待,则所有的线程都会被唤醒,且这些被唤醒的线程必须在返回await之前重新获得锁

例子1

枯燥无聊的理论,看完之后就忘记,还是要写一个例子加深印象吧.这里我们还是用之前`小明`和`小红`谈人生,谈理想的例子继续说明吧

首先要中间人GrilProduct,花花公子PlayBoy和测试类TestMain,都是跟之前[(三)Java多线程之wait notify notifyAll](../test3/(三)java多线程之wait notify notifyAll,md)一样,这里就不占用篇幅了

我们继续改写卧室Room类

public class Room {

Lock lock = new ReentrantLock();

Condition boyIsCome = lock.newCondition();

Condition girlIsCome = lock.newCondition();

private String gril = null;

public void makeGridInRoom(String gril){

lock.lock();

try {

while (this.gril != null){

System.out.println(gril + " 我的心在等待... 永远在等待.. " );

girlIsCome.await();

}

Thread.sleep(10);

this.gril = gril;

boyIsCome.signalAll();

} catch (InterruptedException e) {

e.printStackTrace();

}finally {

lock.unlock();

}

}

public void playWithGril(String boy){

lock.lock();

try {

while (this.gril == null){

System.out.println(boy + " 我的心在等待... 永远在等待.. " );

boyIsCome.await();

}

Thread.sleep(10);

System.out.println(boy + " play with " + this.gril);

Thread.sleep(500);

this.gril = null;

girlIsCome.signal();

} catch (InterruptedException e) {

e.printStackTrace();

} finally {

lock.unlock();

}

}

}

运行一下,结果如下

小红1号 我的心在等待... 永远在等待..

小明0号 play with 小红0号

小明9号 我的心在等待... 永远在等待..

小明2号 我的心在等待... 永远在等待..

小明5号 我的心在等待... 永远在等待..

小明7号 我的心在等待... 永远在等待..

小明4号 我的心在等待... 永远在等待..

小明6号 我的心在等待... 永远在等待..

小明1号 我的心在等待... 永远在等待..

小明3号 我的心在等待... 永远在等待..

小明8号 我的心在等待... 永远在等待..

小红2号 我的心在等待... 永远在等待..

小明9号 play with 小红1号

小明2号 我的心在等待... 永远在等待..

小明5号 我的心在等待... 永远在等待..

小明7号 我的心在等待... 永远在等待..

小明4号 我的心在等待... 永远在等待..

小明6号 我的心在等待... 永远在等待..

小明1号 我的心在等待... 永远在等待..

小明3号 我的心在等待... 永远在等待..

小明8号 我的心在等待... 永远在等待..

小红3号 我的心在等待... 永远在等待..

小明2号 play with 小红2号

小明5号 我的心在等待... 永远在等待..

小明7号 我的心在等待... 永远在等待..

小明4号 我的心在等待... 永远在等待..

小明6号 我的心在等待... 永远在等待..

小明1号 我的心在等待... 永远在等待..

小明3号 我的心在等待... 永远在等待..

小明8号 我的心在等待... 永远在等待..

小红4号 我的心在等待... 永远在等待..

小明5号 play with 小红3号

小明7号 我的心在等待... 永远在等待..

小明4号 我的心在等待... 永远在等待..

小明6号 我的心在等待... 永远在等待..

小明1号 我的心在等待... 永远在等待..

小明3号 我的心在等待... 永远在等待..

小明8号 我的心在等待... 永远在等待..

小红5号 我的心在等待... 永远在等待..

小明7号 play with 小红4号

小明4号 我的心在等待... 永远在等待..

小明6号 我的心在等待... 永远在等待..

小明1号 我的心在等待... 永远在等待..

小明3号 我的心在等待... 永远在等待..

小明8号 我的心在等待... 永远在等待..

小红6号 我的心在等待... 永远在等待..

小明4号 play with 小红5号

小明6号 我的心在等待... 永远在等待..

小明1号 我的心在等待... 永远在等待..

小明3号 我的心在等待... 永远在等待..

小明8号 我的心在等待... 永远在等待..

小红7号 我的心在等待... 永远在等待..

小明6号 play with 小红6号

小明1号 我的心在等待... 永远在等待..

小明3号 我的心在等待... 永远在等待..

小明8号 我的心在等待... 永远在等待..

小红8号 我的心在等待... 永远在等待..

小明1号 play with 小红7号

小明3号 我的心在等待... 永远在等待..

小明8号 我的心在等待... 永远在等待..

小红9号 我的心在等待... 永远在等待..

小明3号 play with 小红8号

小明8号 我的心在等待... 永远在等待..

小明8号 play with 小红9号

跟之前的结果差不多.

例子2

这时候就有人质疑了,既然结果跟用Object.wait和Object.notify一样,那为什么要用这个呢?细心的读者可以发现了,每次运行,同一个小明可能和不同的小红谈人生和理想.这时候小明是很开心.但小红却不乐意,觉得小明太花心,太不专一,什么甜言蜜语都是骗人的.好,那我们现在就让小明专一.帮小红排除他们的烦恼.

这时候全部的类都要改造了,没办法小红太强势了

首先我们改造一下中间人GrilProduct,让每一个小红都自带编号进入卧室等候

public class GrilProduct implements Runnable{

private Room room;

public GrilProduct(Room room) {

this.room = room;

}

@Override

public void run() {

for (int i = 0; i < 10; i ++){

room.makeGridInRoom("小红" + i + "号", i);

}

}

}

之后我们改造花花公子,他们进入房间时,要拿着小红对应的编号进入

public class PlayBoy implements Runnable{

private Room room;

private String boy;

private int index;

public PlayBoy(Room room, String boy, int index) {

this.room = room;

this.boy = boy;

this.index = index;

}

@Override

public void run() {

room.playWithGril(boy, index);

}

}

之后就是要改写卧室类Room了 ,让小红和小明的号码对应上,才让他们谈人生和理想,不然就让他们继续等待..

public class Room {

Lock lock;

List boyIsCome;

Condition girlIsCome;

private String gril = null;

private int index = -1;

public Room(){

lock = new ReentrantLock();

girlIsCome = lock.newCondition();

boyIsCome = new ArrayList<>();

for (int i = 0; i < 10; i ++){

boyIsCome.add(lock.newCondition());

}

}

public void makeGridInRoom(String gril, int index){

lock.lock();

try {

while (this.gril != null){

System.out.println(gril + " 我的心在等待... 永远在等待.. " );

girlIsCome.await();

}

Thread.sleep(10);

this.gril = gril;

this.index = index;

boyIsCome.get(index).signal();

} catch (InterruptedException e) {

e.printStackTrace();

}finally {

lock.unlock();

}

}

public void playWithGril(String boy, int index){

lock.lock();

try {

while (this.gril == null || this.index != index){

System.out.println(boy + " 我的心在等待... 永远在等待.. " );

boyIsCome.get(index).await();

}

Thread.sleep(10);

System.out.println(boy + " play with " + this.gril);

Thread.sleep(500);

this.gril = null;

this.index = -1;

girlIsCome.signal();

} catch (InterruptedException e) {

e.printStackTrace();

} finally {

lock.unlock();

}

}

}

最后改写我们的测试类TestMain

public class TestMain {

public static void main(String[] args) {

Room room = new Room();

Thread grilProduct = new Thread(new GrilProduct(room));

Set boyThread = new HashSet<>();

for (int i = 0; i < 10; i ++){

boyThread.add(new Thread(new PlayBoy(room, "小明" + i + "号", i)));

}

grilProduct.start();

for (Thread boy : boyThread){

boy.start();

}

}

}

运行一下,结果如下:

小红1号 我的心在等待... 永远在等待..

小明9号 我的心在等待... 永远在等待..

小明0号 play with 小红0号

小明2号 我的心在等待... 永远在等待..

小明5号 我的心在等待... 永远在等待..

小明7号 我的心在等待... 永远在等待..

小明4号 我的心在等待... 永远在等待..

小明6号 我的心在等待... 永远在等待..

小明1号 我的心在等待... 永远在等待..

小明3号 我的心在等待... 永远在等待..

小明8号 我的心在等待... 永远在等待..

小红2号 我的心在等待... 永远在等待..

小明1号 play with 小红1号

小红3号 我的心在等待... 永远在等待..

小明2号 play with 小红2号

小红4号 我的心在等待... 永远在等待..

小明3号 play with 小红3号

小红5号 我的心在等待... 永远在等待..

小明4号 play with 小红4号

小红6号 我的心在等待... 永远在等待..

小明5号 play with 小红5号

小红7号 我的心在等待... 永远在等待..

小明6号 play with 小红6号

小红8号 我的心在等待... 永远在等待..

小明7号 play with 小红7号

小红9号 我的心在等待... 永远在等待..

小明8号 play with 小红8号

小明9号 play with 小红9号