Android：线程无限循环/手机过热

Question

我正在处理一个处理所有服务器连接的线程：

public void run() {
    //this initializes Socket and PrintWriter/DataInputStream
    connect(server, port); 

    while(true) {
         //queue is a BlockingQueue where I put the messages to send
         while(!queue.isEmpty()) s
            //COMMUNICATE-WITH-SERVER-CODE
           }
    }   
}

代码有效，但一分钟左右后，我的手机开始过热，电池电量迅速下降。我知道这是因为无限循环。

我该如何解决？我想要一个Thread，它一旦启动，就会保持与服务器的连接（这样DataInputStream 和PrintWriter 就不会每次都被初始化）。而且我希望线程能够响应：当我单击 Button 时，它应该立即向服务器发送一条消息进行处理。

我已经实现了一个Handler 用于与Thread->Activity 通信。但是Activity->Thread怎么沟通呢？

欢迎任何提示。

Answer 1

通常的解决方案是添加一个轮询间隔，例如：每次迭代后让线程休眠 500 毫秒。但在这种情况下，没有必要这样做，因为我们不必轮询BlockingQueue。来自doc

Queue 还支持在检索元素时等待队列变为非空的操作，以及在存储元素时等待队列中可用空间的操作。

如果我们使用BlockingQueue，那么如果队列为空，则 queue.pop() 调用会阻塞并保持阻塞状态，直到有条目被推入队列。因此不需要循环。

但是，我们需要某种机制来防止线程终止。这是一个简单的例子：

public void run() {
    try {
    while (true) {
        handleServerIO(queue.take());
        }
    }catch (InterruptedException ex) {          
     ... handle ...
    }
}