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

溫馨提示×

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
嘉鱼县| 玛多县| 盐亭县| 宁德市| 琼结县| 蓝山县| 连云港市| 高雄县| 三台县| 句容市| 迭部县| 安陆市| 枣庄市| 治多县| 巴里| 方山县| 周口市| 长子县| 桃源县| 浑源县| 沈阳市| 溧阳市| 蓬莱市| 瑞金市| 邓州市| 新建县| 东平县| 霍林郭勒市| 寿宁县| 赣榆县| 襄垣县| 沾益县| 永顺县| 关岭| 璧山县| 深圳市| 平阴县| 麦盖提县| 从江县| 肇州县| 米林县|