User:Jeffkni

Three Body Problem

The Three-Body Problem (三体) https://translate.google.com/?sl=auto&tl=en&text=%E4%B8%89%E4%BD%93&op=translate

Ye Zhetai (叶哲泰) ~ Yay Judd Hai https://translate.google.com/?sl=auto&tl=en&text=%E5%8F%B6%E5%93%B2%E6%B3%B0&op=translate

* Liu Cixin (刘慈欣): %E5%88%98%E6%85%A7%E6%96%8C * Ye Zhetai (叶哲泰): %E5%8F%B6%E5%93%B2%E6%B3%B0 * Shao Lin (绍琳): %E7%A7%80%E5%87%89 * Ye Wenjie (叶文洁): %E5%8F%B6%E6%96%89%E6%9C%89 * Ye Wenxue (叶文雪): %E5%8F%B6%E6%96%89%E5%86%A0 * Lei Zhicheng (雷志成): %E9%9B%B7%E5%90%89%E6%88%90 * Yang Weining (杨卫宁): %E6%9D%A8%E5%8D%81%E5%AE%81 * Wang Miao (汪淼): %E6%B1%AA%E6%B7%B1 * Yang Dong (杨冬): %E6%9D%A8%E5%86%92 * Ding Yi (丁仪): %E4%B8%87%E4%BA%AA * Shi Qiang (史强): %E5%8F%B2%E5%BC%BA * Da Shi (大史): %E5%A4%A7%E5%8F%B2 * Chang Weisi (常伟思): %E5%B8%B8%E5%85%A8%E6%80%9D * Shen Yufei (申玉菲): %E7%94%B3%E7%8E%89%E8%8F%B2 * Wei Cheng (魏成): %E9%AD%8F%E6%88%90 * Pan Han (潘寒): %E6%BD%98%E5%86%B7 * Sha Ruishan (沙瑞山): %E6%B2%99%E7%91%9E%E5%B1%B1 * Mozi (墨子): %E5%BD%95%E5%AD%90

import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future;

public class Test {

   public void run() {
       Runtime.getRuntime().addShutdownHook(new Thread(() -> {
           System.out.println("Shutdown");
       }));

       System.out.println("Starting processing ...");
       List<String> results = Arrays.asList("a", "b", "c");
       List<Callable<String>> callables = new ArrayList<>();
       for (String docId : results) {

           callables.add(() -> {
               System.out.println("Running " + docId);
               return "ok-" + docId;
           });
       }

       ExecutorService executorService = Executors.newFixedThreadPool(5);
       System.out.println("Processing futures ...");
       try {
           List<Future<String>> futures = executorService.invokeAll(callables);
           for (Future<String> future : futures) {
               System.out.println("Got future " + future.get());
           }

           System.out.println("done");
       } catch (InterruptedException | ExecutionException e) {
           System.out.println("Error");
       } finally {
           executorService.shutdown();
       }
   }

   public static void main(String[] args) {
       new Test().run();
   }

}