线程池阻塞队列详解

DGBM • 2024-10-10 08:46 • 编程

一、线程池阻塞队列有哪几种

线程池阻塞队列有四种类型的阻塞队列：

无界队列
有界队列
SynchronousQueue
DelayQueue

二、线程池阻塞队列的选择

根据业务特点，我们需要选择合适的阻塞队列类型。如果线程池的线程数是无限的，可以选择无界队列；如果线程池的线程数是有限的，可以选择有界队列或SynchronousQueue；如果需要实现延迟执行任务，可以选择DelayQueue。

三、线程池阻塞队列的概念

线程池阻塞队列是指在任务提交到线程池后，如果线程池的线程数量已经达到最大值，那么剩余的任务将会被放到一个阻塞队列中，这个队列就是线程池的阻塞队列。

四、线程池阻塞队列大小设置

线程池阻塞队列大小设置与业务需求有关。如果业务中提交的任务量较大，可以适当增加队列大小，以避免任务被拒绝。但是要注意，队列过大可能会导致oom，因此需要在合理的范围内设置队列大小。

五、线程池阻塞队列源码

public interface BlockingQueue extends Queue {
    //添加元素到队尾，如果队列已满，将会阻塞
    void put(E e) throws InterruptedException;

    //从队头获取元素，如果队列为空，将会阻塞
    E take() throws InterruptedException;
}

public class LinkedBlockingQueue extends AbstractQueue implements BlockingQueue, Serializable {
    //默认队列大小为Integer.MAX_VALUE
    public LinkedBlockingQueue() {
        this(Integer.MAX_VALUE);
    }

    //指定队列大小
    public LinkedBlockingQueue(int capacity) {
        if (capacity <= 0) throw new IllegalArgumentException();
        this.capacity = capacity;
        last = head = new Node(null);
    }

    private static class Node {
        E item;
        Node next;
        Node(E x) { item = x; }
    }

    //添加元素到队尾，如果队列已满，将会阻塞
    public void put(E e) throws InterruptedException {
        if (e == null) throw new NullPointerException();
        int c = -1;
        Node node = new Node(e);
        final ReentrantLock putLock = this.putLock;
        final AtomicInteger count = this.count;
        putLock.lockInterruptibly();
        try {
            while (count.get() == capacity) {
                notFull.await();
            }
            enqueue(node);
            c = count.getAndIncrement();
            if (c + 1  1)
                notEmpty.signal();
        } finally {
            takeLock.unlock();
        }
        if (c == capacity)
            signalNotFull();
        return x;
    }
}

六、线程池阻塞队列与拒绝策略

线程池阻塞队列与拒绝策略是相辅相成的，当任务提交到线程池后，如果线程池中的线程已经达到最大值并且线程池阻塞队列已经满了，就需要使用拒绝策略处理剩余的任务。

七、线程池阻塞队列的作用

线程池阻塞队列的作用是缓存任务，避免任务被拒绝。当线程池中的线程数量已经达到最大值后，剩余的任务就会放到阻塞队列中等待处理。

八、线程池阻塞队列导致oom

线程池阻塞队列如果过大，可能会导致oom。因此，在设置队列大小时需要注意避免过大。

九、线程池阻塞队列满了

当线程池阻塞队列满了，新提交的任务就会被拒绝。此时可以使用拒绝策略来处理剩余的任务。

十、线程池阻塞队列的长度选取

选择线程池阻塞队列的长度应该考虑业务需求。如果任务量很大，可以适当增加队列大小；如果希望更快的响应任务，可以适当减小队列大小。

原创文章，作者：DGBM，如若转载，请注明出处：https://www.506064.com/n/141976.html