Android中使用生产者消费者队列时如何避免出队线程高CPU占用

嘿，这个场景我之前做Android物联网通信的时候正好碰到过！你的推测完全正确——入队线程因为udpSocket.receive(packet)是阻塞式系统调用，没有数据包到来时线程会被内核挂起，根本不会占用CPU资源。但出队线程如果只是裸写while(true)不断轮询队列，那肯定会陷入空转，把CPU使用率拉满。

这里给你两个最靠谱的解决方案，都是利用LinkedBlockingQueue本身的阻塞特性来避免空转：

1. 使用take()方法（推荐） #

LinkedBlockingQueue的take()方法是阻塞式的：当队列中没有元素时，调用这个方法的线程会进入等待状态，直到有新元素入队才会被唤醒。这样出队线程就不会空转，CPU占用会立刻降下来。

示例代码：

// 假设这是你的全局队列
private LinkedBlockingQueue<DatagramPacket> packetQueue = new LinkedBlockingQueue<>();

// 出队线程的逻辑
private class DequeueThread extends Thread {
    @Override
    public void run() {
        super.run();
        while (!Thread.currentThread().isInterrupted()) {
            try {
                // 队列空时自动阻塞，不占用CPU
                DatagramPacket packet = packetQueue.take();
                // 处理UDP数据包的业务逻辑
                processReceivedPacket(packet);
            } catch (InterruptedException e) {
                // 捕获中断信号，优雅退出线程
                Thread.currentThread().interrupt();
                break;
            }
        }
    }
}

关键注意点：

• 一定要处理InterruptedException：当你需要停止出队线程时，调用thread.interrupt()就能唤醒阻塞中的take()方法，然后通过中断标记优雅退出循环，避免线程变成僵尸线程。
• 这个方法是效率最高的，因为线程等待是操作系统内核级别的，不会消耗CPU时间片。

2. 使用poll()方法（支持超时等待） #

如果你需要在队列空的时候做一些周期性的轻量操作（比如检查线程状态、打印日志），可以用poll(long timeout, TimeUnit unit)方法。它会等待指定时间，如果超时还没有元素就返回null，这样也不会一直空转。

示例代码：

private class DequeueThread extends Thread {
    @Override
    public void run() {
        super.run();
        while (!Thread.currentThread().isInterrupted()) {
            try {
                // 等待1秒，超时返回null
                DatagramPacket packet = packetQueue.poll(1, TimeUnit.SECONDS);
                if (packet != null) {
                    processReceivedPacket(packet);
                } else {
                    // 队列空时的轻量操作，比如检查是否要停止线程
                    if (Thread.currentThread().isInterrupted()) {
                        break;
                    }
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                break;
            }
        }
    }
}

避坑提醒：不要用isEmpty()+Thread.sleep() #

很多人一开始会想到用if (queue.isEmpty()) { Thread.sleep(100); }来避免空转，但这种方式很不优雅：

• 睡眠时间太短（比如10ms）还是会频繁唤醒线程，占用CPU；
• 睡眠时间太长（比如1s）会导致数据包处理延迟，实时性下降；
• 不如队列原生的阻塞方法高效，因为sleep()是线程主动放弃时间片，而take()是内核等待唤醒，响应更快。

内容的提问来源于stack exchange，提问作者Amarjit Dhillon