ExecutorService pool = Executors.newFixedThreadPool(3); List<Future<JestClient>> list = Lists.newArrayList(); for(int i=0;i<4;i++){ Future<JestClient> submit = pool.submit(new Callable<JestClient>() { public JestClient call() throws Exception { JestClient client = EsFactory.getClient(); System.out.PRintln(Thread.currentThread().getName() + "--->" + System.currentTimeMillis() + "---" + client); return client; } }); list.add(submit); } for(Future<JestClient> fut:list){ System.out.println(Thread.currentThread().getName()+"---"+fut.get()); }
新闻热点
疑难解答