我如何实现带有超时的Runnable？

Question

我目前有一个相当简单的SSL服务器/客户端项目，其中涉及标准Java后端和Android前端。与客户端发送数据后，我想尝试从服务器读取响应。但是，我遇到了一个小问题。服务器并不总是响应，因此我不得不以某种方式尝试以异步方式获取响应。 （因为read（）方法是一个阻塞的方法），经过一番混乱之后，我找到了一个可行的解决方案，但对我来说似乎很奇怪，就像Im正在做可能“危险”的事情一样。我做的第一件事是创建一个新的Runnable和Thread对象：

                    //  "reader" is of type "BufferedReader"             

                    Runnable receiveResponse = new Runnable() {
                        boolean stop = false;
                        @Override
                        public void run() {
                            try {
                                new Timer().schedule(new TimerTask() {
                                    @Override
                                    public void run() {
                                        stop = true;
                                    }
                                }, 5000);
                                char receive;
                                StringBuilder responseBuilder = new StringBuilder();
                                while (!stop && ((receive = (char) reader.read()) != END_OF_STREAM_CHAR)) {
                                    responseBuilder.append(receive);
                                }
                                // If the server responds in time I can continue processing the response etc.
                            } catch (Exception ex) {
                                // Handle exception ...
                            }
                        }
                    };
                    Thread thread = new Thread(receiveResponse);
                    thread.start();

您可以看到，我在while循环中使用了一个布尔“停止”（5秒钟后设置为true）作为附加条件。“ reader.read（）”方法是一种阻塞方法，因此，如果我不实施某种类型的线程停止方法，则该方法将无限期地阻塞服务器，如果服务器没有响应。这就是为什么我尝试使用仅将“ stop”布尔值设置为true的Timer的原因。

我知道这不是最好的解决方案，有时我会重新设计整个事情，但是我仍然想知道我现在正在做的事情是否还可以。当然可以，但是可悲的是没有任何意义。

Answer 1

您是对的，这种从另外一个线程开始的方法并不完美。很难支持这样的代码。

我建议改用Thread Executor。您的代码可能如下所示：

Runnable receiveResponse = new Runnable() {
    ...
};

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<?> future = executor.submit(receiveResponse);

try {
    Object result = future.get(5000, TimeUnit.MILLISECONDS);
    System.out.println("Completed successfully");
} catch (InterruptedException e) {
    ...
} catch (ExecutionException e) {
    ...
} catch (TimeoutException e) {
    System.out.println("Timed out. Cancelling the runnable...");
    future.cancel(true);
}

executor.shutdown();