91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

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
深水埗区| 江北区| 胶南市| 安远县| 历史| 昌江| 宁陕县| 曲靖市| 龙州县| 莒南县| 抚顺县| 奎屯市| 平原县| 治多县| 祁门县| 西盟| 郎溪县| 榆树市| 凤凰县| 大竹县| 福海县| 兴和县| 建始县| 彭州市| 迁安市| 通山县| 延吉市| 宕昌县| 西安市| 炎陵县| 杭锦旗| 怀安县| 如皋市| 航空| 安岳县| 徐闻县| 阿城市| 措美县| 巴楚县| 凤台县| 贵定县|