java - 在java中执行多个线程每个线程一定时间

Question

我正在将文件发送到创建文件的本地服务器。当用户一个接一个地执行多个操作时，我的问题就出现了，如果其中一个请求在 5 分钟内没有获得反馈文件，我需要显示一条错误消息。

我如何处理所有这些请求？我使用 newSingleThreadScheduledExecutor 来检查反馈文件是否每分钟都存在，但我不知道如何处理多个反馈文件并在 5 分钟的情况下保持每个请求的倒计时。我的尝试:

ListeningExecutorService executor = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(listPrinter.size()));
        for(int i=0;i<list.size();i++){
            try {

                final File retrievedFile = new File("/home/"+list.get(i)+".csv");

                ListenableFuture<File> future = executor.submit(new Callable<File>() {
                    public File call() {
                        // Actually send the file to your local server
                        // and retrieve a file back

                        if(retrievedFile.exists())
                        {
                            new Notification("file exits").show(Page.getCurrent());
                        }
                        else{
                            new Notification("file no exits").show(Page.getCurrent());
                        }
                        return retrievedFile;
                    }
                });
                future.get(5, TimeUnit.MINUTES);
            } catch (InterruptedException ex) {
                Exceptions.printStackTrace(ex);
            } catch (ExecutionException ex) {
                Exceptions.printStackTrace(ex);
            } catch (TimeoutException ex) {
                Exceptions.printStackTrace(ex);
                new Notification("Time out").show(Page.getCurrent());
            }
        }

但它只是在开始时执行，仅此而已，但是当添加文件时什么也没有发生。

是否可以使用 watchService 来做到这一点？它对我来说效果很好，但我不知道 5 分钟的情况

Answer 1

看看 Future 界面:

http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html

应该完全适合您的问题。

当你运行一个线程时，结果可能是一个 Future，它是一个异步任务的结果，你可以为你正在启动的每个异步任务拥有一个 Future。

Future<File> sendReceiveFile(File inputFile) {
    final Future<File> future = new YourFuture<File>(...);
    new Thread() {
        @Override
        public void run() {
            File outputFile = null;
            try {
                 outputFile = SendFileToServer(inputFile);
            } catch (final Exception e) {
                // do something
            } finally {
                future.setValue(fileOutput);
            }
        }
    }.start();
    return future;
}

在你的主要部分:

Future<File> future = sendReceiveFile(myFile);
File outputFile = null;
try {
    outputFile = future.get(1, TimeUnit.MINUTE);
} catch(TimeOutException e) {
    // do something
}