JUC 八股20 - 线程池1(阻塞队列)

public interface BlockingQueue<E> extends Queue<E> {
  boolean add(E e);

  // 入队，如果队列已满，返回false否则返回true（非阻塞）
  boolean offer(E e);

  // 入队，如果队列已满，该线程会被阻塞，直到能入队为止
  void put(E e) throws InterruptedException;

  // 入队，如果队列已满，阻塞线程直到能入队或超时、中断为止
  // 入队成功返回true否则false
  boolean offer(E e, long timeout, TimeUnit unit)
      throws InterruptedException;

  // 出队，如果队列为空，该线程被阻塞，直到能出队为止
  E take() throws InterruptedException;

  // 出队，如果队列为空，阻塞线程直到能出队超时、中断为止
  // 出队成功正常返回，否则返回null
  E poll(long timeout, TimeUnit unit)
      throws InterruptedException;

  // 返回此队列理想情况下（在没有内存或资源限制的情况下）可以不阻塞地入队的数量
  // 如果没有限制，则返回 Integer.MAX_VALUE
  int remainingCapacity();

  boolean remove(Object o);

  public boolean contains(Object o);

  // 一次性从BlockingQueue中获取所有可用的数据对象
  // （还可以指定获取数据的个数）
  int drainTo(Collection<? super E> c);

  int drainTo(Collection<? super E> c, int maxElements);
}

final ReentrantLock lock;
private final Condition notEmpty;
private final Condition notFull;

public void put(E e) throws InterruptedException {
  final ReentrantLock lock = this.lock;
  lock.lockInterruptibly(); // 🔹 加锁，确保线程安全
  try {
      while (count == items.length) { // 🔹 队列满，阻塞
          notFull.await();
      }
      enqueue(e); // 🔹 插入元素
  } finally {
      lock.unlock(); // 🔹 释放锁
  }
}

ArrayBlockingQueue<Integer> blockingQueue = new ArrayBlockingQueue<Integer>(10, true);

BlockingQueue<Integer> pool = new LinkedBlockingQueue<>(poolSize);