下面程序代碼通過使用Lock鎖執(zhí)行簡單的流水線任務(wù)：

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(); } }}

執(zhí)行結(jié)果如下：

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

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

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。