中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

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
丰顺县| 淮滨县| 金塔县| 信丰县| 丹寨县| 北京市| 石城县| 启东市| 沽源县| 琼海市| 冕宁县| 洛阳市| 河曲县| 岑溪市| 师宗县| 大荔县| 巨野县| 西和县| 寿宁县| 剑河县| 开原市| 沙洋县| 苍溪县| 法库县| 辉县市| 秭归县| 大方县| 洱源县| 四会市| 平南县| 阳新县| 西峡县| 大田县| 临安市| 阿鲁科尔沁旗| 元江| 察隅县| 偃师市| 斗六市| 甘孜县| 万全县|