线程间定制化通信---按顺序执行线程

Posted 2023-01-24 weixin_ancenhw

启动三个线程：
AA线程打印5次，BB打印6次，CC打印3次

  //定义标记
    private int flag = 1;

    private Lock lock = new ReentrantLock();

    //定义锁状态
    private Condition c1 = lock.newCondition();
    private Condition c2 = lock.newCondition();
    private Condition c3 = lock.newCondition();

    public void loopThread()
        lock.lock();
        try 
            while (flag!=1)
                c1.wait();
            
            for (int i = 0; i < 5; i++) 
                System.out.println(Thread.currentThread()+"执行次数:"+i);
            
            flag=2;
            c2.signal();
         catch (InterruptedException e) 
            e.printStackTrace();
        finally 
            lock.unlock();
        
    

    public void loopThread2()
        lock.lock();
        try 
            while (flag!=2)
                c2.wait();
            
            for (int i = 0; i < 6; i++) 
                System.out.println(Thread.currentThread()+"执行次数:"+i);
            
            flag=3;
            c3.signal();
         catch (InterruptedException e) 
            e.printStackTrace();
        finally 
            lock.unlock();
        
    

    public void loopThread3()
        lock.lock();
        try 
            while (flag!=3)
                c3.wait();
            
            for (int i = 0; i < 3; i++) 
                System.out.println(Thread.currentThread()+"执行次数:"+i);
            

         catch (InterruptedException e) 
            e.printStackTrace();
        finally 
            lock.unlock();
        
    



    @Test
    public void contextLoads() 
        new Thread(()->
            loopThread();
        ,"AA").start();

        new Thread(()->
            loopThread2();
        ,"BB").start();

        new Thread(()->
            loopThread3();
        ,"CC").start();