import java.util.concurrent.Semaphore;/**Semaphore信號量 基于AQS（內部維護了一個隊列）可以用于限流 最多允許多少線程同時運行可以有很多個線程 但同時允許運行的線程有限制2個 new Semaphore(2) */ public class T11_TestSemaphore {public static void main(String[] args) {//允許一個線程同時執行// Semaphore s = new Semaphore(1);// 允許兩個纖程同時執行Semaphore s = new Semaphore(2);//2 同時允許兩個線程運行 true 公平與否 默認非公平// Semaphore s = new Semaphore(2, true);new Thread(()->{try {s.acquire();//獲得許可 一共就2個許可System.out.println("T1 running...");Thread.sleep(200);System.out.println("T1 running...");} catch (InterruptedException e) {e.printStackTrace();} finally {s.release();}}).start();new Thread(()->{try {s.acquire();System.out.println("T2 running...");Thread.sleep(200);System.out.println("T2 running...");} catch (InterruptedException e) {e.printStackTrace();} finally {s.release();}}).start();} }

總結

以上是生活随笔為你收集整理的【完整代码】使用Semaphore实现限流代码示例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。