import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import com.armadillojava.Task; import com.armadillojava.ThreadPool; public class MultiThreadApplication { public static void main(String[] args) { ThreadPoolExecutor threadPool = ThreadPool.createFixedThreadPool(5); try { Future<Integer> future = threadPool.submit(new MyTask()); int result = future.get(); e.printStackTrace(); } finally { threadPool.shutdown(); } } static class MyTask implements Task<Integer> { @Override public Integer execute() { int sum = 0; for (int i = 1; i <= 100; i++) { sum += i; } return sum; } } }


上一篇:
下一篇:
切换中文