示例部分代碼:文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-737962.html
String param = "hello"
//舉例用的線程池,一般建議自定義線程池
ExecutorService executorService = Executors.newFixedThreadPool(5);
CompletionService<Object> completionService = new ExecutorCompletionService<>(executorService);
completionService.submit(new Callable<Integer>() {
@Override
public Integer call() throws Exception {
// 模擬耗時(shí)任務(wù)
return simulationService.get(param);
}
});
Object res= Future<Integer> future = completionService.take().get();
// 關(guān)閉線程池
executorService.shutdown();
文章來(lái)源:http://www.zghlxwxcb.cn/news/detail-737962.html
到了這里,關(guān)于java多線程異步處理并獲取處理后的返回值的文章就介紹完了。如果您還想了解更多內(nèi)容,請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!