Java - 如何测量超时

Question

我正在使用 Java 套接字制作一个 ping 程序。我的程序中的一个错误是有时它无法连接，并且会永远坐在那里。所以我试图添加一个超时（二十秒后），ping 将失败。但我不知道该怎么做。

这是我的 ping 程序的一部分：

boolean result = false;
long before1 = System.nanoTime();
out.println(new byte[64]);
System.out.println("(1) Sent 64 bytes of data to " + address
                    + "...");
try {
    if ((in.readLine()) != null) {
        int size = in.readLine().toString().getBytes().length;
        long after = System.nanoTime();
        long s = ((after - before1) / 1000000L) / 1000;
        System.out.println("(1) Recieved reply from " + address
            + " (" + size + " bytes), time = " + s
                + " seconds...");
        result = true;
    } else if ((in.readLine()) == null) {
        long after = System.nanoTime();
        long s = ((after - before1) / 1000000L) / 1000;
        System.out.println("(1) Failed to recieve reply from "
            + address + ", time = " + s + " seconds...");
            result = false;
    }

} catch (IOException exc) {

    long after = System.nanoTime();
    long s = ((after - before1) / 1000000L) / 1000;
    System.err.println("(1) Failed to recieve reply from "
        + address + ", time = " + s + " seconds...\nReason: "
                        + exc);
    result = false;

}

但我想在代码中的任何位置测量经过的时间，而不是：

long time = System.nanoTime();

如果我的代码的一部分被卡住了，它会在 20 秒后超时。
关于如何测量是否在 try/catch 块开始或我的代码中的其他任何地方已经过去了 20 秒，以便它不会在 ping 期间卡住的任何建议？

Answer 1

正如“jsn”和“jahory”所说，您需要使用线程来执行此操作。这里有 2 个有用的链接，您可以查看它们；）

• How to implement timeout using threads

• Adding a thread timeout to methods in Java

Answer 2

您可以使用Future 和FutureTask：

   ExecutorService pingExecutor = ... // executor service to run the ping in other thread

   void showPing(final String target) throws InterruptedException {

     Future<String> ping = executor.submit(new Callable<String>() {
         public String call() {
             String pingResult = ... // do your Ping stuff
             return pingResult;
         }});

     System.out.println("Pinging..."); // do other things while searching

     try {
       System.out.println(future.get(20, TimeUnit.SECONDS)); // use future, waits 20 seconds for the task to complete
     } catch (ExecutionException ex) {
     } catch (TimeoutException tex) {
       // Ping timed out
     }
   }

Answer 3

你可以在这里找到一些提示：How do I call some blocking method with a timeout in Java?

未来的界面看起来可以很好地解决您的问题。但是请记住，根据您的任务正在做什么，您可能无法真正取消它。附加信息：

• tutorial (see, in particular, Non-blocking algorithms section)