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

溫馨提示×

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
崇信县| 宁城县| 包头市| 兴城市| 黄平县| 彩票| 分宜县| 宣威市| 满洲里市| 茶陵县| 长宁县| 麻江县| 精河县| 临夏市| 巴东县| 中阳县| 子洲县| 珲春市| 林甸县| 商都县| 乌苏市| 海盐县| 琼结县| 金寨县| 石河子市| 德昌县| 乌恰县| 新兴县| 津南区| 义马市| 屏南县| 鹿邑县| 德保县| 琼中| 绥化市| 衡阳县| 湟中县| 安吉县| 唐河县| 新密市| 拉萨市|