如何实现带超时的 Runnable？

Question

我目前有一个相当简单的 SSL server/client 项目，它涉及一个标准 Java 后端和一个 Android 前端。我想在与客户端发送数据后尝试从服务器读取响应。但是，我遇到了一个小问题。服务器并不总是响应，所以我不得不以某种方式尝试以异步方式获得响应。（因为 read() 方法是一个阻塞方法）经过一番摸索后，我找到了一个可行的解决方案，但对我来说这似乎很奇怪，就像我在做一些可能 "dangerous" 的事情一样。我做的第一件事是创建一个新的 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 循环中使用了一个布尔值 "stop"（我在 5 秒后设置为 true）作为附加条件。 "reader.read()" 方法是一种阻塞方法，因此如果我不实施某种类型的停止线程，如果服务器不响应，此方法将阻塞无限长的时间。这就是为什么我尝试使用简单地将 "stop" 布尔值设置为 true 的定时器。

我知道这不是最好的解决方案，在某些时候我会重新设计整个东西，但我仍然想知道我现在做的事情是否合适。它当然有效，但遗憾的是这并不意味着什么。

Answer 1

你说得对，这种多开一个线程的做法并不完美。很难支持这样的代码。

我建议改用 线程执行器。您的代码可能如下所示：

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();

如何实现带超时的 Runnable？

How can I implement a Runnable with timeout?

java

asynchronous

timeout

runnable