下面程序代碼通過使用Lock鎖執行簡單的流水線任務：

import java.util.concurrent.locks.Condition;import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantLock;/** * @author lzq * @data 2020/4/29 0029 - 下午 9:48 */public class TestLock { public static void main(String[] args) { DataSource dataSource=new DataSource(); new Thread(() -> { for (int i=0;i<10;i++){dataSource.a(); } },'A').start(); new Thread(() -> { for (int i=0;i<10;i++){dataSource.b(); } },'B').start(); new Thread(() -> { for (int i=0;i<10;i++){dataSource.c(); } },'C').start(); }}class DataSource{ private int x=1; private Lock lock=new ReentrantLock(); private Condition condition1=lock.newCondition(); private Condition condition2=lock.newCondition(); private Condition condition3=lock.newCondition(); public void a(){ lock.lock(); try { while(x!=1){condition1.await(); } System.out.println(Thread.currentThread().getName()+':aaa'); x=2; condition2.signal(); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); } } public void b(){ lock.lock(); try { while(x!=2){condition2.await(); } System.out.println(Thread.currentThread().getName()+':bbb'); x=3; condition3.signal(); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); } } public void c(){ lock.lock(); try { while(x!=3){condition3.await(); } System.out.println(Thread.currentThread().getName()+':ccc'); x=1; condition1.signal(); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); } }}

執行結果如下：

對于上面代碼簡單分析：代碼中包含簡單的生產者消費者流程和Lock實現三部曲，即重復判斷條件，執行邏輯，喚醒其他線程和產生鎖，加鎖，解鎖。注意這里一點，條件判斷一定要重復判斷，不然可能會導致線程假醒影響結果。

因為當線程處于等待狀態時，線程會釋放資源，等到被喚醒的時候，從上次await的地方醒來繼續執行，這時條件判斷成立，執行await，其他線程再修改條件使得本線程被喚醒，此時本線程不會繼續判斷，而是繼續執行，如果使用循環判斷就能檢驗出條件被修改。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持好吧啦網。