c 阻塞队列 多线程

Java中的阻塞队列（Blocking Queue）是一个多线程并发编程中常用的数据结构，它可以在某些条件下挂起线程，并在条件满足时自动唤醒。阻塞队列提供了一种线程安全的方式来实现生产者-消费者模型。

阻塞队列位于java.util.concurrent包中，简称JUC。它提供了许多与多线程并发相关的组件操作。阻塞队列可以通过以下方式进行初始化：

BlockingQueue<String> blockingQueue = new LinkedBlockingQueue<>(); //基于链表来实现，可以指定阻塞队列的大小

阻塞队列的核心方法有以下几种类型：
1. 插入方法：add(e)、offer(e)、put(e)、offer(e,time,unit)
- 如果队列已满，再往队列中插入元素会抛出异常或返回特殊值。
2. 移除方法：remove()、poll()、take()、poll(time,unit)
- 如果队列为空，从队列中移除元素会抛出异常或返回特殊值。
3. 检查方法：element()、peek()
- 检查队列的头部元素，如果队列为空，element()方法会抛出异常，peek()方法会返回null。

阻塞队列的特性包括：
- 抛出异常：当阻塞队列满时，再往队列中添加元素会抛出异常IllegalStateException，当阻塞队列空时，移除队列中的元素会抛出异常NoSuchElementException。
- 特殊值：插入方法成功时返回true，失败时返回false；移除方法成功时返回队列的元素，队列为空时返回null。
- 一直阻塞：当阻塞队列满时，生产者线程继续往队列中放入元素，队列会一直阻塞生产者线程，直到生产者线程put数据或响应中断退出；当阻塞队列空时，消费者线程试图从队列中取出元素，队列会一直阻塞消费者线程，直到队列可用。
- 超时退出：当阻塞队列满时，队列会阻塞线程一定时间，超过时间后生产者线程会退出。

可以通过创建多个线程作为生产者或消费者来使用阻塞队列。以下是一个示例：

public static void main(String[] args) {
    BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(); //作为交易场所

    Thread t1 = new Thread() { //作为生产者
        public void run() {
            for (int i = 0; i < 1000; i++) {
                try {
                    queue.put(i);
                    System.out.println("生产元素生产了" + i + "个");
                    sleep(1000); //每秒钟生产一个元素
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    };
    t1.start();

    Thread t2 = new Thread() { //作为消费者
        public void run() {
            while (true) {
                //频繁取队首元素
                int num = queue.take();
                System.out.println("消费元素为" + num);
            }
        }
    };
    t2.start();
}