使用阻塞队列BlockingQueue实现生产者消费者

    xiaoxiao2021-12-14  30

    BlockingQueue有一组阻塞的方法:

    put() 方法:当队列容量达到最大,自动阻塞

    take() 方法:当队列容量为0,自动阻塞

    使用 BlockingQueue实现的生产者消费者简单测试代码如下:

    package com.cjy.concurrent; import java.util.concurrent.LinkedBlockingQueue; class Producer extends Thread{ LinkedBlockingQueue<String> queue; public Producer(LinkedBlockingQueue<String> queue) { this.queue = queue; } @Override public void run() { try { int i = 0; for (int k = 20; k > 0; k--) { System.out.println("生产者生产产品:" + String.valueOf(i)+" [队列大小:"+queue.size()+"]"); queue.put(String.valueOf(i)); i++; } } catch (InterruptedException e) { e.printStackTrace(); } } } class Consumer extends Thread { LinkedBlockingQueue<String> queue; public Consumer(LinkedBlockingQueue<String> queue) { this.queue = queue; } @Override public void run() { try { for (int j = 20; j > 0; j--) { String s = (String) queue.take(); System.out.println("**消费者消费产品***: " + s+" [队列大小:"+queue.size()+"]"); } } catch (InterruptedException e) { e.printStackTrace(); } } } public class ProducterCustomer { public static LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<String>(3); public static void main(String[] args) { Producer producer = new Producer(queue); Consumer consumer = new Consumer(queue); ((Producer) producer).start(); ((Consumer) consumer).start(); } }

    测试结果:

    生产者生产产品:0       [ 队列大小:0 ] 生产者生产产品:1       [ 队列大小:1 ] 生产者生产产品:2       [ 队列大小:1 ] **消费者消费产品***: 0       [ 队列大小:1 ] **消费者消费产品***: 1       [ 队列大小:1 ] 生产者生产产品:3       [ 队列大小:2 ] **消费者消费产品***: 2       [ 队列大小:0 ] 生产者生产产品:4       [ 队列大小:1 ] **消费者消费产品***: 3       [ 队列大小:0 ] 生产者生产产品:5       [ 队列大小:1 ] **消费者消费产品***: 4       [ 队列大小:0 ] **消费者消费产品***: 5       [ 队列大小:0 ] 生产者生产产品:6       [ 队列大小:1 ] 生产者生产产品:7       [ 队列大小:1 ] 生产者生产产品:8       [ 队列大小:1 ] 生产者生产产品:9       [ 队列大小:2 ] **消费者消费产品***: 6       [ 队列大小:0 ] 生产者生产产品:10       [ 队列大小:3 ] 生产者生产产品:11       [ 队列大小:3 ] **消费者消费产品***: 7       [ 队列大小:2 ] **消费者消费产品***: 8       [ 队列大小:2 ] 生产者生产产品:12       [ 队列大小:3 ] **消费者消费产品***: 9       [ 队列大小:2 ] **消费者消费产品***: 10       [ 队列大小:2 ] 生产者生产产品:13       [ 队列大小:3 ] 生产者生产产品:14       [ 队列大小:2 ] 生产者生产产品:15       [ 队列大小:3 ] **消费者消费产品***: 11       [ 队列大小:1 ] **消费者消费产品***: 12       [ 队列大小:2 ] 生产者生产产品:16       [ 队列大小:2 ] 生产者生产产品:17       [ 队列大小:3 ] **消费者消费产品***: 13       [ 队列大小:2 ] **消费者消费产品***: 14       [ 队列大小:2 ] **消费者消费产品***: 15       [ 队列大小:1 ] 生产者生产产品:18       [ 队列大小:2 ] 生产者生产产品:19       [ 队列大小:2 ] **消费者消费产品***: 16       [ 队列大小:1 ] **消费者消费产品***: 17       [ 队列大小:2 ] **消费者消费产品***: 18       [ 队列大小:1 ] **消费者消费产品***: 19       [ 队列大小:0 ]

    转载请注明原文地址: https://ju.6miu.com/read-964786.html

    最新回复(0)