用Lock跟Condition,实现主线程执行5次,子线程再执行10次,孙线程执行15次,如此反复5次
用Lock和Condition,实现主线程执行5次,子线程再执行10次,孙线程执行15次,如此反复5次
package test1; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * 用Lock和Condition,实现主线程执行5次,子线程再执行10次,孙线程执行15次,如此反复5次 * * 设计思想: * 业务类Business中,设计3个方法,每个方法代表主、子、孙 * 主方法中执行5次 * 子方法中执行10次 * 孙方法中执行15次 * * 用lock锁住各自方法,然后用runFlag来判断是否自己执行,如果不是,则await,如果走完,则把runFlag设为下一个要执行的对象 * 然后用condition来唤醒下一线程 * */ public class CommunicationTest3 { public static void main(String[] args) { final Business2 business = new Business2(); new Thread(new Runnable() { @Override public void run() { for (int i = 0; i < 5; i++) { business.sub2(i); } } }){}.start(); new Thread(new Runnable() { @Override public void run() { for (int i = 0; i < 5; i++) { business.sub3(i); } } }){}.start(); for (int i = 0; i < 5; i++) { business.sub(i); } } } class Business2 { private int runFlag = 1; private Lock lock = new ReentrantLock(); Condition c1 = lock.newCondition(); Condition c2 = lock.newCondition(); Condition c3 = lock.newCondition(); public void sub(int i) { lock.lock(); try { if (runFlag != 1) { try { c1.await(); // 如果不是sub1执行时,让出CPU } catch (Exception e) { e.printStackTrace(); } } for (int j = 0; j < 5; j++) { System.out.println("sub1-" + i + "下的" + j + "次"); } runFlag = 2; // 执行完后,让sub执行 c2.signal(); } finally { lock.unlock(); } } public void sub2(int i) { lock.lock(); try { if (runFlag != 2) { try { c2.await(); // 如果不是sub2该执行时,让出CPU } catch (Exception e) { e.printStackTrace(); } } for (int j = 0; j < 10; j++) { System.out.println("sub2-" + i + "下的" + j + "次"); } runFlag = 3; // 执行完后,让sub执行 c3.signal(); } finally { lock.unlock(); } } public void sub3(int i) { lock.lock(); try { if (runFlag != 3) { try { c3.await(); // 如果不是sub3该执行时,让出CPU } catch (Exception e) { e.printStackTrace(); } } for (int j = 0; j < 15; j++) { System.out.println("sub3-" + i + "下的" + j + "次"); } runFlag = 1; // 执行完后,让sub1执行 c1.signal(); } finally { lock.unlock(); } } }