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

溫馨提示×

java怎么實現生產者消費者模型

小億
82
2024-09-26 01:32:01
欄目: 編程語言

在Java中,生產者消費者模型可以通過使用線程同步機制(如synchronized關鍵字、Lock接口、Semaphore信號量等)和wait()、notifyAll()等待通知機制實現。這里給出一個簡單的示例,使用synchronized關鍵字和wait()、notifyAll()方法實現生產者消費者模型。

首先,創建一個共享資源類(共享隊列):

import java.util.LinkedList;
import java.util.Queue;

public class SharedQueue {
    private Queue<Integer> queue = new LinkedList<>();

    public synchronized void add(int item) {
        while (queue.size() == 10) {
            try {
                wait(); // 當前線程等待,釋放鎖
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        queue.add(item);
        notifyAll(); // 當前線程通知其他線程
    }

    public synchronized int remove() {
        while (queue.isEmpty()) {
            try {
                wait(); // 當前線程等待,釋放鎖
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        int item = queue.poll();
        notifyAll(); // 當前線程通知其他線程
        return item;
    }
}

接下來,創建生產者和消費者線程類:

public class Producer implements Runnable {
    private SharedQueue sharedQueue;

    public Producer(SharedQueue sharedQueue) {
        this.sharedQueue = sharedQueue;
    }

    @Override
    public void run() {
        for (int i = 0; i < 20; i++) {
            sharedQueue.add(i);
            System.out.println("生產者生產了: " + i);
            try {
                Thread.sleep(100); // 模擬生產耗時
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Consumer implements Runnable {
    private SharedQueue sharedQueue;

    public Consumer(SharedQueue sharedQueue) {
        this.sharedQueue = sharedQueue;
    }

    @Override
    public void run() {
        for (int i = 0; i < 20; i++) {
            int item = sharedQueue.remove();
            System.out.println("消費者消費了: " + item);
            try {
                Thread.sleep(200); // 模擬消費耗時
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

最后,在主類中創建生產者和消費者線程并啟動:

public class Main {
    public static void main(String[] args) {
        SharedQueue sharedQueue = new SharedQueue();
        Producer producer = new Producer(sharedQueue);
        Consumer consumer = new Consumer(sharedQueue);

        Thread producerThread = new Thread(producer);
        Thread consumerThread = new Thread(consumer);

        producerThread.start();
        consumerThread.start();
    }
}

運行上述代碼,可以看到生產者和消費者線程交替執行,生產者生產商品放入共享隊列,消費者從共享隊列取出商品。這樣就實現了一個簡單的生產者消費者模型。

0
宣汉县| 晋州市| 榆树市| 宁远县| 吉安市| 太仓市| 正定县| 马山县| 麦盖提县| 贵阳市| 盘锦市| 宣汉县| 昌吉市| 定南县| 贺兰县| 柏乡县| 寿阳县| 沙洋县| 宣威市| 南岸区| 西盟| 繁峙县| 寻甸| 剑川县| 施秉县| 桂东县| 玉环县| 淮安市| 班玛县| 沙坪坝区| 淮北市| 平定县| 自贡市| 马鞍山市| 宝山区| 夏河县| 东至县| 祁东县| 龙井市| 昭通市| 贡山|