java异步线程_java异步线程

使用一个ExecutorService，增加两个不可取消的子线程任务，并且获取他们的返回值。

@org.junit.Test

public void testFuture() throws InterruptedException {

ExecutorService executor = Executors.newCachedThreadPool();

Task task = new Task();

NewTask newTask = new NewTask();

Future result = executor.submit(task);

Future ends = executor.submit(newTask);

executor.shutdown();

System.out.println("主线程开始运行");

System.out.println("主线程做一些复杂任务");

Thread.sleep(10000);

System.out.println("主线程需要子线程的计算结果");

try {

System.out.println("主线程得到子线程的结果："+result.get());

System.out.println("主线程需要第二个子线程的数据:"+ends.get());

} catch (InterruptedException e) {

e.printStackTrace();

} catch (ExecutionException e) {

e.printStackTrace();

}

System.out.println("所有均完毕");

}

}

class Task implements Callable{

public Integer call() throws Exception {

System.out.println("子线程计算开始");

Thread.sleep(3000);

int sum = 0;

for (int i=0;i<100000;i++){

sum += i ;

}

System.out.println("子线程已经计算完毕");

return sum;

}

}

class NewTask implements Callable{

public String call() throws Exception {

System.out.println("第二个子线程已经运行完毕");

return "success";

}

}

另： 如果main主线程不去获取子线程的结果，那么主线程完全可以不阻塞。那么，此时，主线程和子线程完全异步。此功能，可以做成类似MQ消息中间件之类的，消息异步进行发送。

使用一个ExecutorService，增加两个不可取消的子线程任务，并且获取他们的返回值。 @org.junit.Test public void testFuture() throws InterruptedException { ExecutorService executor = Executors.newCachedThreadPool(); Task task = new Task(); NewTask newTask = new NewTask(); Future result = executor.submit(task); Future ends = executor.submit(newTask); executor.shutdown(); System.out.println("主线程开始运行"); System.out.println("主线程做一些复杂任务"); Thread.sleep(10000); System.out.println("主线程需要子线程的计算结果"); try { System.out.println("主线程得到子线程的结果："+result.get()); System.out.println("主线程需要第二个子线程的数据:"+ends.get()); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } System.out.println("所有均完毕"); } } class Task implements Callable{ public Integer call() throws Exception { System.out.println("子线程计算开始"); Thread.sleep(3000); int sum = 0; for (int i=0;i<100000;i++){ sum += i ; } System.out.println("子线程已经计算完毕"); return sum; } } class NewTask implements Callable{ public String call() throws Exception { System.out.println("第二个子线程已经运行完毕"); return "success"; } } 另： 如果main主线程不去获取子线程的结果，那么主线程完全可以不阻塞。那么，此时，主线程和子线程完全异步。此功能，可以做成类似MQ消息中间件之类的，消息异步进行发送。