package tj.pojo.generate.main;import java.util.ArrayList;
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;
import java.util.concurrent.FutureTask;public class ConcurrentCalculator {private ExecutorService exec;private int cpuCoreNumber;private List<Future<Long>> tasks = new ArrayList<Future<Long>>();// 内部类class SumCalculator implements Callable<Long> {private int[] numbers;private int start;private int end;public SumCalculator(final int[] numbers, int start, int end) {this.numbers = numbers;this.start = start;this.end = end;}@Overridepublic Long call() throws Exception {Long sum = 0L;for (int i = start; i < end; i++) {sum += numbers[i];}System.out.println(String.format("%s~%s的和为%s", start, end, sum));return sum;}}public ConcurrentCalculator() {cpuCoreNumber = Runtime.getRuntime().availableProcessors();System.out.println("CPU核心数：" + cpuCoreNumber);exec = Executors.newFixedThreadPool(cpuCoreNumber);}public Long sum(final int[] numbers) {for (int i = 0; i < cpuCoreNumber; i++) {int increment = numbers.length / cpuCoreNumber + 1;int start = increment * i;int end = start + increment;if (end > numbers.length) {end = numbers.length;}SumCalculator task = new SumCalculator(numbers, start, end);FutureTask<Long> future = new FutureTask<Long>(task);tasks.add(future);System.out.println("添加一个任务，总任务数为：" + tasks.size());if (!exec.isShutdown()) {exec.submit(future);// ExecutoreService提供了submit()方法，传递一个Callable，或Runnable，返回Future。// exec.submit(task);
            }}System.out.println("任务分配完成，总任务数为：" + tasks.size());return getResult();}public Long getResult() {Long sums = 0L;for (Future<Long> task : tasks) {try {Long sum = task.get();sums += sum;System.out.println("当前总合计：" + sums);} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}}return sums;}public void close() {exec.shutdown();}
}

                exec.submit(future);// ExecutoreService提供了submit()方法，传递一个Callable，或Runnable，返回Future。// exec.submit(task);

public static void test() {int[] numbers = new int[100];for (int i = 0; i < 100; i++) {numbers[i] = i + 1;}tj.pojo.generate.main.ConcurrentCalculator cc = new tj.pojo.generate.main.ConcurrentCalculator();Long sum = cc.sum(numbers);System.out.println("1~100的和为" + sum);cc.close();}

public class Test {public static void main(String[] args) {ExecutorService executor = Executors.newCachedThreadPool();Task task = new Task();Future<Integer> result = executor.submit(task);executor.shutdown();try {Thread.sleep(1000);} catch (InterruptedException e1) {e1.printStackTrace();}System.out.println("主线程在执行任务");try {System.out.println("task运行结果"+result.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}System.out.println("所有任务执行完毕");}
}
class Task implements Callable<Integer>{@Overridepublic Integer call() throws Exception {System.out.println("子线程在进行计算");Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++)sum += i;return sum;}
}

public class Test {public static void main(String[] args) {//第一种方式ExecutorService executor = Executors.newCachedThreadPool();Task task = new Task();FutureTask<Integer> futureTask = new FutureTask<Integer>(task);executor.submit(futureTask);executor.shutdown();//第二种方式，注意这种方式和第一种方式效果是类似的，只不过一个使用的是ExecutorService，一个使用的是Thread/*Task task = new Task();FutureTask<Integer> futureTask = new FutureTask<Integer>(task);Thread thread = new Thread(futureTask);thread.start();*/try {Thread.sleep(1000);} catch (InterruptedException e1) {e1.printStackTrace();}System.out.println("主线程在执行任务");try {System.out.println("task运行结果"+futureTask.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}System.out.println("所有任务执行完毕");}
}
class Task implements Callable<Integer>{@Overridepublic Integer call() throws Exception {System.out.println("子线程在进行计算");Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++)sum += i;return sum;}
}