condition

多线程之间按照顺序调用，实现A->B->C,

三个线程启动，要求如下，

A打印5次，B打印10次，C打印15次，

反复重复10轮。

import java.util.concurrent.locks.*;

class ShareResource {

	private int number=1;
	private Lock lock=new ReentrantLock();
	private Condition condition1=lock.newCondition();
	private Condition condition2=lock.newCondition();
	private Condition condition3=lock.newCondition();

	public void println5() {
		lock.lock();
		try {
			while(number!=1) {
				condition1.await();

			}
			for (int i=1; i<=5; i++) {
				System.out.println(Thread.currentThread().getName()+"\t"+i);
			}
			number=2;
			condition2.signal();
		}catch(Exception e) {
			e.printStackTrace();
		}finally {
			lock.unlock();
		}
	}

	public void println10() {
		lock.lock();
		try {
			while(number!=2) {
				condition2.await();

			}
			for (int i=1; i<=10; i++) {
				System.out.println(Thread.currentThread().getName()+"\t"+i);
			}
			number=3;
			condition3.signal();
		}catch(Exception e) {
			e.printStackTrace();
		}finally {
			lock.unlock();
		}
	}

	public void println15() {
		lock.lock();
		try {
			while(number!=3) {
				condition3.await();

			}
			for (int i=1; i<=15; i++) {
				System.out.println(Thread.currentThread().getName()+"\t"+i);
			}
			number=1;
			condition1.signal();
		}catch(Exception e) {
			e.printStackTrace();
		}finally {
			lock.unlock();
		}
	}
}

public class ThreadOrderAccess {
	public static void main(String[] args) {
		ShareResource sr=new ShareResource();

		new Thread(() -> {
			for (int i=0; i<10; i++) {
				sr.println5();
			}
		},"A").start();

		new Thread(() -> {
			for (int i=0; i<10; i++) {
				sr.println10();
			}
		},"B").start();

		new Thread(() -> {
			for (int i=0; i<10; i++) {
				sr.println15();
			}
		},"C").start();	
	}
}

Condition 是一种更细粒度的并发解决方案。

就拿生产者消费者模式来说，当仓库满了的时候，又再执行到生产者线程的时候，会把该生产者线程进行阻塞，再唤起一个线程，

但是此时唤醒的是消费者线程还是生产者线程，是未知的。

如果再次唤醒的还是生产者线程，那么还需要把它进行阻塞，再唤起一个线程，再此循环，直到唤起的是消费者线程。

condition

全站热榜