最近2018中文字幕在日韩欧美国产成人片_国产日韩精品一区二区在线_在线观看成年美女黄网色视频_国产精品一区三区五区_国产精彩刺激乱对白_看黄色黄大色黄片免费_人人超碰自拍cao_国产高清av在线_亚洲精品电影av_日韩美女尤物视频网站

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
JAVA多線程使用Lock,Condition實現(xiàn)A,B,C,D依次執(zhí)行,怎么實現(xiàn)排它,同步通訊

這篇文章主要介紹“JAVA多線程使用Lock,Condition實現(xiàn)A,B,C,D依次執(zhí)行,怎么實現(xiàn)排它,同步通訊”,在日常操作中,相信很多人在JAVA多線程使用Lock,Condition實現(xiàn)A,B,C,D依次執(zhí)行,怎么實現(xiàn)排它,同步通訊問題上存在疑惑,小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”JAVA多線程使用Lock,Condition實現(xiàn)A,B,C,D依次執(zhí)行,怎么實現(xiàn)排它,同步通訊”的疑惑有所幫助!接下來,請跟著小編一起來學(xué)習(xí)吧!

成都創(chuàng)新互聯(lián)公司是專業(yè)的吳堡網(wǎng)站建設(shè)公司,吳堡接單;提供網(wǎng)站設(shè)計、網(wǎng)站建設(shè),網(wǎng)頁設(shè)計,網(wǎng)站設(shè)計,建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行吳堡網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊,希望更多企業(yè)前來合作!

package com.study;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;


public class BlockingQueueDemo {
  public static void main(String[] args) {
    BlockingQueueDemo blockingQueueDemo = new BlockingQueueDemo();
    final BlockingQueueClass blockingQueueClass = blockingQueueDemo.new BlockingQueueClass();
    Thread thread = new Thread(new Runnable() {

      @Override
      public void run() {
        while (true) {
          blockingQueueClass.invokeA();
        }
      }
    });
    thread.start();

    Thread thread2 = new Thread(new Runnable() {

      @Override
      public void run() {
        while (true) {
          blockingQueueClass.invokeB();
        }
      }
    });
    thread2.start();
    
    Thread thread3 = new Thread(new Runnable() {

      @Override
      public void run() {
        while (true) {
          blockingQueueClass.invokeC();
        }
      }
    });
    thread3.start();
    
    Thread thread4 = new Thread(new Runnable() {

      @Override
      public void run() {
        while (true) {
          blockingQueueClass.invokeD();
        }
      }
    });
    thread4.start();
  }

  class BlockingQueueClass {
    Lock lock = new ReentrantLock();
    Condition conditionA = lock.newCondition();
    Condition conditionB = lock.newCondition();
    Condition conditionC = lock.newCondition();
    Condition conditionD = lock.newCondition();
    boolean syncA = true;
    boolean syncB = false;
    boolean syncC = false;
    boolean syncD = false;

    public void invokeA() {
      lock.lock();
      try {
        while (!syncA) {
          try {
            conditionA.await();
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        syncA = false;
        syncB = true;
        System.out.println("invoke A....");
        conditionB.signal();
      } catch (Exception e) {
        e.printStackTrace();
      } finally {
        lock.unlock();
      }
    }
    
    public void invokeB() {
      lock.lock();
      try {
        while (!syncB) {
          try {
            conditionB.await();
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        syncB = false;
        syncC = true;
        System.out.println("invoke B....");
        conditionC.signal();
      } catch (Exception e) {
        e.printStackTrace();
      } finally {
        lock.unlock();
      }
    }
    
    public void invokeC() {
      lock.lock();
      try {
        while (!syncC) {
          try {
            conditionC.await();
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        syncC = false;
        syncD = true;
        System.out.println("invoke C....");
        conditionD.signal();
      } catch (Exception e) {
        e.printStackTrace();
      } finally {
        lock.unlock();
      }
    }
    public void invokeD() {
      lock.lock();
      try {
        while (!syncD) {
          try {
            conditionD.await();
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        syncD = false;
        syncA = true;
        System.out.println("invoke D....");
        conditionA.signal();
      } catch (Exception e) {
        e.printStackTrace();
      } finally {
        lock.unlock();
      }
    }
  }
}

到此,關(guān)于“JAVA多線程使用Lock,Condition實現(xiàn)A,B,C,D依次執(zhí)行,怎么實現(xiàn)排它,同步通訊”的學(xué)習(xí)就結(jié)束了,希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學(xué)習(xí),快去試試吧!若想繼續(xù)學(xué)習(xí)更多相關(guān)知識,請繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站,小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>
新聞標(biāo)題:JAVA多線程使用Lock,Condition實現(xiàn)A,B,C,D依次執(zhí)行,怎么實現(xiàn)排它,同步通訊
分享網(wǎng)址:http://fisionsoft.com.cn/article/ppgeii.html