在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
}

Answer 2

您可以手动执行此操作，但使用 Guava ListenableFuture 会更好：

// Here we create a fixed thread pool with 10 threads and an inifinite-capacity queue
ListeningExecutorService executor = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10));

final File fileToSend = ...; // 

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

Futures.addCallback(future, new FutureCallback<File>() {

    public void onSuccess(File retrievedFile) {
        // Handle the successfully retrieved file when it returns
    }

    public void onFailure(Throwable thrown) {
        // Handle the error
    }
});

通过异步发送文件，您可以在任何给定时间发送和检索许多文件。然后，当服务器响应时（使用检索到的文件或错误），您可以在响应（检索到的文件或异常）返回时处理它，而无需等待它。这意味着当本地服务器有可用响应时，onSuccess() 或 onFailure() 方法将自动执行。

Answer 3

我通过使用Timer 解决了这个问题，该5 分钟执行一次，获取过去 5 分钟内发生的所有db 事务并且没有得到任何响应并显示我的错误代码。它工作得很好。谢谢大家的帮助