欢迎您访问365答案网,请分享给你的朋友!
生活常识 学习资料

生产者消费者(阻塞队列)

时间:2023-08-03

阻塞队列实现等待唤醒机制

BlockingQueue 的核心方法:

put(anObect) 将参数放入队列,如果放不进去会阻塞。

take():取出第一个数据,取不到会阻塞。

常见BlockingQueue:

ArrayBlockingQueue:底层是数组,有界。

linkedBlockingQueue:底层是链表,无界。但不是真正的无界,最大为int的最大值

阻塞队列继承结构

Iterabe-> Colection -> Queue ->BlockingQueue -> ArrBlockingQueue

                                                                             -> linkedBlockingQueue

package threadDemo15;

import java.util.concurrent.ArrayBlockingQueue;

public class Coodie extends Thread{
    private  ArrayBlockingQueue list;
    
    public Coodie(ArrayBlockingQueue list) {
        this.list = list;
    }

    @Override
    public void run() {
       while(true){
        try {
            list.put("汉堡包");
            System.out.println("厨师放了一个汉堡包");
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    }
}
 

package threadDemo15;

import java.util.concurrent.ArrayBlockingQueue;

public class Cooker extends Thread{
    private ArrayBlockingQueue list;
    
     public Cooker(ArrayBlockingQueue list) {
        this.list = list;
    }

    @Override
    public void run() {
        while(true){
        try {
            String take = list.take();
            System.out.println("吃货从队列中获取了"+take);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    }
}
 

package threadDemo15;

import java.util.concurrent.ArrayBlockingQueue;

public class Demo {
// 阻塞队列的基本用法
    
    // 创建阻塞队列的对象,容量为1
    public static void main(String[] args) throws InterruptedException {
        // TODO Auto-generated method stub
        ArrayBlockingQueue list = new ArrayBlockingQueue(1);
    
     
        Cooker c = new Cooker(list);
        Coodie f = new Coodie(list);
        
        c.start();
        f.start();
        
    }

}
 

Copyright © 2016-2020 www.365daan.com All Rights Reserved. 365答案网 版权所有 备案号:

部分内容来自互联网,版权归原作者所有,如有冒犯请联系我们,我们将在三个工作时内妥善处理。