import java.util.concurrent.Semaphore;import java.util.concurrent.ThreadLocalRandom;/** * 利用semaphore的先V(release)再P(acquire)操作,实现线程的前置依赖关系。 * semaphore的容量是0 */public class SemaphorePVDemo { public static void main(String[] args) { Semaphore semaphore1 = new Semaphore(0); Semaphore semaphore2 = new Semaphore(0); new Thread(()->{ try { Thread.sleep(ThreadLocalRandom.current().nextInt(5000)); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("线程1最先工作"); semaphore1.release(); }).start(); new Thread(()->{ try { semaphore1.acquire(); Thread.sleep(ThreadLocalRandom.current().nextInt(5000)); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("线程2然后工作"); semaphore2.release(); }).start(); new Thread(()->{ try { semaphore2.acquire(); Thread.sleep(ThreadLocalRandom.current().nextInt(5000)); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("线程3最后工作"); }).start(); }}
點擊查看更多內(nèi)容
為 TA 點贊
評論
評論
共同學習,寫下你的評論
評論加載中...
作者其他優(yōu)質(zhì)文章
正在加載中
感謝您的支持,我會繼續(xù)努力的~
掃碼打賞,你說多少就多少
贊賞金額會直接到老師賬戶
支付方式
打開微信掃一掃,即可進行掃碼打賞哦