优化用于发送网络数据的 Android 线程

Question

我正在使用一个应用程序，它使用两个线程来读取数据并将数据发送到服务器。每个线程运行一个while循环；一个 que 包含一组命令，这些命令被 dequed 发送到服务器。这样我就可以将大量的命令排成队列并一一发送到服务器。

命令发送者是这样的

 class writeThread extends AsyncTask<Object, Object, Object>
 {
    byte[] buffer;
    LittleEndianDataOutputStream outputStream;
    @Override
    protected void onPreExecute() 
    {

    }
    @Override
    protected Object doInBackground(Object... params) 
    {
        try
        {
            buffer = new byte[4096];
            outputStream = new LittleEndianDataOutputStream(dataHolder.connection.getOutputStream());

            try
            {
                dataHolder.flags latestFlag;
                while (true)
                {
                    try 
                    {
                        latestFlag = dataHolder.sendFlags.remove();
                        ByteBuffer sendBytes = ByteBuffer.allocate(128);
                        sendBytes.order(ByteOrder.LITTLE_ENDIAN);
                        switch (latestFlag) 
                        {
                            case sendDataRequest:
                                sendBytes.putInt(20);
                                outputStream.write(sendBytes.array());
                                break;
                            case getSelectedData:
                                sendBytes.putInt(21);
                                sendBytes.put(dataHolder.latestSelected.getBytes());
                                outputStream.write(sendBytes.array());
                                break;
                            case disconnect:
                                sendBytes.putInt(254);
                                sendBytes.put(dataHolder.latestSelected.getBytes());
                                outputStream.write(sendBytes.array());
                                break;                                    

                        }


                    }
                    catch (NoSuchElementException ex){}
                }
            }
            catch (IOException ex) {}

        }
        catch (Exception ex){};
        return null;

    }


}

读取循环如下所示

     while (inputStream.read() > -1)

因此，应用程序最终占用了手机 50% 的处理能力。有没有关于如何优化socket监听和数据发送的建议？

注意：是的，我知道我正在对队列使用 try catch 而不是 if 语句来检查队列是否为空。我确信抛出错误无助于优化，但我认为它不会将处理器推到 50%。如果您需要更多信息，请告诉我。

Answer 1

您的实现的问题在于您基本上是在忙着等待 - 如果没有要发送的内容，它会立即转到异常处理程序并再次尝试 - 从而占用该内核上的所有 cpu。

您想要的是一种等待事件可用的方法。我建议您创建一个HandlerThread，并使用与该线程关联的 Handler 来处理对数据流的写入。

HandlerThread handlerThread = new HandlerThread("blah");
handlerThread.start();
Handler handler = new Handler(handlerThread.getLooper()) {
    public boolean HandleMessage(Message msg) {
        switch (msg.what) {
            case sendDataRequest:
               ...
            case getSelectedData:
               ...
            case disconnect:
               ...
        }
    }
}

然后您将创建具有适当 id 和数据的消息，并使用 handler.sendMessage() 将它们发送到处理程序

或者（也许更简单），如果您将 dataHolder.sendFlags 集合设为 ArrayBlockingQueue，而不是当前的任何内容（我猜是 ArrayList 或类似的？），那么当您使用ArrayBlockingQueue.take()，它会一直等到有东西可用（没有执行占用所有可用 cpu 时间的繁忙等待）