亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

Java中SynchronousQueue隊列怎么實現排隊

小億
99
2024-01-22 09:35:15
欄目: 編程語言

在Java中,SynchronousQueue隊列是一種特殊的阻塞隊列,其主要特點是只能同時有一個元素在隊列中,當一個線程嘗試將一個元素放入隊列時,它會被阻塞,直到另一個線程嘗試從隊列中取出該元素。

要實現排隊功能,可以使用SynchronousQueue的offer()方法和take()方法來實現。

以下是一個簡單的示例代碼:

import java.util.concurrent.SynchronousQueue;

public class QueueExample {
    private static SynchronousQueue<String> queue = new SynchronousQueue<>();

    public static void main(String[] args) {
        // 創建多個線程
        for (int i = 0; i < 5; i++) {
            Thread thread = new Thread(() -> {
                try {
                    String name = Thread.currentThread().getName();
                    System.out.println(name + " 正在排隊...");
                    queue.offer(name); // 將線程名稱放入隊列
                    System.out.println(name + " 排隊成功,開始工作");
                    Thread.sleep(1000);
                    System.out.println(name + " 工作完成,離開隊列");
                    queue.take(); // 從隊列中取出線程名稱
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
            thread.start();
        }
    }
}

在這個示例中,創建了5個線程,每個線程都會嘗試將自己的名稱放入隊列中,然后等待其他線程取出自己的名稱。當一個線程被阻塞時,其他線程會繼續執行,直到被阻塞的線程被喚醒。

注意,SynchronousQueue隊列不存儲元素,只是作為線程間通信的中介,因此在使用過程中要確保有其他線程來取出隊列中的元素,否則會導致線程一直阻塞。

0
陆良县| 盐亭县| 江城| 宝丰县| 类乌齐县| 成安县| 镇坪县| 保山市| 贺兰县| 九龙坡区| 永丰县| 奉新县| 马尔康县| 上犹县| 瑞丽市| 酉阳| 喀喇沁旗| 汝州市| 遂宁市| 泾川县| 二连浩特市| 堆龙德庆县| 嘉善县| 崇阳县| 宜州市| 郸城县| 高州市| 商河县| 上栗县| 景德镇市| 分宜县| 大名县| 萨迦县| 南澳县| 寻乌县| 门头沟区| 二手房| 温泉县| 闽侯县| 青河县| 姜堰市|