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

溫馨提示×

Java中synchronousqueue怎么使用

小億
87
2024-01-19 19:11:31
欄目: 編程語言

在Java中,可以使用SynchronousQueue來實現線程之間的同步通信。SynchronousQueue是一個不存儲元素的阻塞隊列,它的主要特點是生產者線程必須等待消費者線程消費完元素后才能繼續生產新的元素。

以下是使用SynchronousQueue的示例代碼:

import java.util.concurrent.SynchronousQueue;

public class SynchronousQueueExample {
    public static void main(String[] args) {
        SynchronousQueue<Integer> queue = new SynchronousQueue<>();

        // 創建生產者線程
        Thread producer = new Thread(() -> {
            try {
                int value = 1;
                while (true) {
                    // 將元素放入隊列
                    queue.put(value);
                    System.out.println("生產者生產了:" + value);
                    value++;
                    // 模擬生產者生產時間
                    Thread.sleep(1000);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // 創建消費者線程
        Thread consumer = new Thread(() -> {
            try {
                while (true) {
                    // 從隊列中取出元素
                    int value = queue.take();
                    System.out.println("消費者消費了:" + value);
                    // 模擬消費者消費時間
                    Thread.sleep(2000);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // 啟動生產者和消費者線程
        producer.start();
        consumer.start();
    }
}

在上述代碼中,首先創建了一個SynchronousQueue實例。然后創建了一個生產者線程,不斷地生產元素并放入隊列中。創建了一個消費者線程,不斷地從隊列中取出元素進行消費。生產者和消費者線程同時運行,但生產者必須等待消費者消費完元素后才能繼續生產新的元素,這樣就實現了線程之間的同步。

0
彩票| 崇义县| 裕民县| 驻马店市| 银川市| 怀来县| 青铜峡市| 阿拉尔市| 平陆县| 武穴市| 庆安县| 漾濞| 威信县| 桂阳县| 塘沽区| 荣昌县| 连山| 阳曲县| 定安县| 沁阳市| 新竹县| 青浦区| 阆中市| 宁南县| 象州县| 唐山市| 始兴县| 郧西县| 饶河县| 柳林县| 永宁县| 云龙县| 孟州市| 瓦房店市| 英超| 大化| 梅州市| 太和县| 海门市| 张家口市| 小金县|