在我编写的 Web 服务器中,每个请求都会调用一个操作列表。其中一些操作不像其他操作那么重要,所以我想在后台线程中运行它们。
此外,由于它们并不那么重要,我不在乎它们中的一个是否很少失败,并且我不希望它们永远占用一个线程,因此其他线程将可用于处理下一批。
所以,我想要一个线程池(例如:10个线程)并像这样为每个后台任务分配一个线程。将每个线程限制为 1 秒,如果到此时间还没有完成,则将其杀死,以便下一个任务进入。
我该怎么做呢?
到目前为止,这就是我所拥有的:
public class AsyncCodeRunner {
private static final ExecutorService executor = Executors.newFixedThreadPool(10);
public void Run(Callable<Void> callableCode, int timeout) {
final int threadTimeout = 10;
Future<Void> callableFuture = executor.submit(callableCode);
try {
callableFuture.get(threadTimeout, TimeUnit.SECONDS);
} catch (Exception e) {
logger.Info("Thread was timed out", e);
}
}
}
我想像这样使用这个类:
public void processRequest(RequestObject request) {
// do some important processing
// throw some less important processing to background thread
(new AsyncCodeRunner()).Run(new Callable<Void> () {
@Override
public Void call() throws Exception {
// do something...
return null;
}
}, 1); // 1 second timeout
// return result (without waiting for background task)
return;
}
这会像我想要的那样工作吗?或者我应该如何改变它呢?
如果我打电话Run()
但线程池中没有可用的线程可以分发怎么办?