从Java线程返回值

Question

我有一个如下的Java线程：

   public class MyThread extends Thread {
        MyService service;
        String id;
        public MyThread(String id) {
            this.id = node;
        }
        public void run() {
            User user = service.getUser(id)
        }
    }

我大约有300个ID，每隔几秒钟-我启动线程以对每个ID进行呼叫。例如。

for(String id: ids) {
    MyThread thread = new MyThread(id);
    thread.start();
}

现在，我想从每个线程收集结果，并批量插入数据库，而不是每2秒进行300次数据库插入。

知道我该如何做到吗？

Answer 1

如果要在执行数据库更新之前收集所有结果，则可以使用该invokeAll方法。如daveb建议的那样，如果您一次提交一项任务，则可以完成簿记工作。

private static final ExecutorService workers = Executors.newCachedThreadPool();

...

Collection<Callable<User>> tasks = new ArrayList<Callable<User>>();
for (final String id : ids) {
  tasks.add(new Callable<User>()
  {

    public User call()
      throws Exception
    {
      return svc.getUser(id);
    }

  });
}
/* invokeAll blocks until all service requests complete, 
 * or a max of 10 seconds. */
List<Future<User>> results = workers.invokeAll(tasks, 10, TimeUnit.SECONDS);
for (Future<User> f : results) {
  User user = f.get();
  /* Add user to batch update. */
  ...
}
/* Commit batch. */
...