condition使用及分析

野性酷女 2023-05-28 11:23 2阅读 0赞

### 基本介绍 ###

Condition是在java 1.5中才出现的，它用来替代传统的Object的wait()、notify()实现线程间的协作，相比使用Object的wait()、notify()，使用Condition的await()、signal()这种方式实现线程间协作更加安全和高效。因此通常来说比较推荐使用Condition，阻塞队列实际上是使用了Condition来模拟线程间协作。

1.  Condition是个接口，基本的方法就是await()和signal()方法；
2.  Condition依赖于Lock接口，生成一个Condition的基本代码是lock.newCondition()
3.  调用Condition的await()和signal()方法，都必须在lock保护之内，就是说必须在lock.lock()和lock.unlock之间才可以使用
    
    > Conditon中的await()对应Object的wait()；  
    > Condition中的signal()对应Object的notify()；  
    > Condition中的signalAll()对应Object的notifyAll()。

### 代码示例 ###

下面一个场景，需要ABC3个线程，A线程打印5次，然后是B线程打印10次，再是C线程打印15次，线程交替打印，来10轮：分析：

1.  ABC线程需要交替执行，我们需要控制，线程的执行先后顺序
2.  我们可以使用多条件Condition来控制，每一个线程拥有一个condition对象，调用各种的await方法，可以使线程等待，然后让别的线程调用这个condition对象的signal方法，唤醒线程。
3.  代码如下：

public class ConditionTest { 
        // A = 1,B=2, C= 3
        private int data = 1;
        private Lock lock = new ReentrantLock();
        Condition condition1 = lock.newCondition();
        Condition condition2 = lock.newCondition();
        Condition condition3 = lock.newCondition();
    
    
       public void printA() { 
           lock.lock();
           try { 
               while (data != 1) { 
                   condition1.await();
               }
               // 打印5次
               for (int i = 0; i < 5; i++) { 
                   System.out.println(Thread.currentThread().getName() + " ->" + data);
               }
               data = 2;
               // 通知B线程
               condition2.signal();
           } catch (Exception e) { 
               e.printStackTrace();
           } finally { 
               lock.unlock();
           }
       }
    
        public void printB() { 
            lock.lock();
            try { 
                while (data != 2) { 
                    condition2.await();
                }
                // 打印10次
                for (int i = 0; i < 10; i++) { 
                    System.out.println(Thread.currentThread().getName() + " ->" + data);
                }
                data = 3;
                // 通知C
                condition3.signal();
            } catch (Exception e) { 
                e.printStackTrace();
            } finally { 
                lock.unlock();
            }
        }
    
        public void printC() { 
            lock.lock();
            try { 
                while (data != 3) { 
                    condition3.await();
                }
                // 打印15次
                for (int i = 0; i < 15; i++) { 
                    System.out.println(Thread.currentThread().getName() + " ->" + data);
                }
                data = 1;
                // 通知A
                condition1.signal();
            } catch (Exception e) { 
                e.printStackTrace();
            } finally { 
                lock.unlock();
            }
        }
    
        public static void main(String[] args) { 
            ConditionTest conditionTest = new ConditionTest();
            new Thread(new Runnable() { 
                @Override
                public void run() { 
                    for (int i = 0; i < 10; i++) { 
                        conditionTest.printA();
                    }
                }
            }, "A").start();
    
            new Thread(new Runnable() { 
                @Override
                public void run() { 
                    for (int i = 0; i < 10; i++) { 
                        conditionTest.printB();
                    }
                }
            }, "B").start();
    
            new Thread(new Runnable() { 
                @Override
                public void run() { 
                    for (int i = 0; i < 10; i++) { 
                        conditionTest.printC();
                    }
                }
            }, "C").start();
        }
    }

执行结果可以自己去运行，ABC3个线程会交替打印。