解决任意的多线程并行、串行、阻塞、依赖、回调的并行框架

package parallel; import com.jd.platform.async.executor.Async; import com.jd.platform.async.executor.timer.SystemClock; import com.jd.platform.async.wrapper.WorkerWrapper; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executors; /** * 并行测试 * * @author wuweifeng wrote on 2019-11-20. */ @SuppressWarnings("ALL") public class TestPar { public static void main(String[] args) throws Exception { // testNormal(); // testMulti(); // testMultiReverse(); // testMultiError2(); // testMulti3(); // testMulti3Reverse(); // testMulti4(); // testMulti4Reverse(); // testMulti5(); // testMulti5Reverse(); // testMulti6(); // testMulti7(); // testMulti8(); // testMulti9(); testMulti9Reverse(); } /** * 3个并行，测试不同时间的超时 */ private static void testNormal() throws InterruptedException, ExecutionException { ParWorker w = new ParWorker(); ParWorker1 w1 = new ParWorker1(); ParWorker2 w2 = new ParWorker2(); WorkerWrapper<String, String> workerWrapper2 = new WorkerWrapper.Builder<String, String>() .worker(w2) .callback(w2) .param("2") .build(); WorkerWrapper<String, String> workerWrapper1 = new WorkerWrapper.Builder<String, String>() .worker(w1) .callback(w1) .param("1") .build(); WorkerWrapper<String, String> workerWrapper = new WorkerWrapper.Builder<String, String>() .worker(w) .callback(w) .param("0") .build(); long now = SystemClock.now(); System.out.println("begin-" + now); Async.beginWork(1500, workerWrapper, workerWrapper1, workerWrapper2); // Async.beginWork(800, workerWrapper, workerWrapper1, workerWrapper2); // Async.beginWork(1000, workerWrapper, workerWrapper1, workerWrapper2); System.out.println("end-" + SystemClock.now()); System.err.println("cost-" + (SystemClock.now() - now)); System.out.println(Async.getThreadCount()); System.out.println(workerWrapper.getWorkResult()); Async.shutDown(); } /** * 0,2同时开启,1在0后面 * 0---1 * 2 */ private static void testMulti() throws ExecutionException, InterruptedException { ParWorker w = new ParWorker(); ParWorker1 w1 = new ParWorker1(); ParWorker2 w2 = new ParWorker2(); WorkerWrapper<String, String> workerWrapper2 = new WorkerWrapper.Builder<String, String>() .worker(w2) .callback(w2) .param("2") .build(); WorkerWrapper<String, String> workerWrapper1 = new WorkerWrapper.Builder<String, String>() .worker(w1) .callback(w1) .param("1") .build(); WorkerWrapper<String, String> workerWrapper = new WorkerWrapper.Builder<String, String>() .worker(w) .callback(w) .param("0") .next(workerWrapper1) .build(); long now = SystemClock.now(); System.out.println("begin-" + now); Async.beginWork(2500, workerWrapper, workerWrapper2); System.out.println("end-" + SystemClock.now()); System.err.println("cost-" + (SystemClock.now() - now)); Async.shutDown(); } /** * 0,2同时开启,1在0后面 * 0---1 * 2 */ private static void testMultiReverse() throws ExecutionException, InterruptedException { ParWorker w = new ParWorker(); ParWorker1 w1 = new ParWorker1(); ParWorker2 w2 = new ParWorker2(); WorkerWrapper<String, String> workerWrapper = new WorkerWrapper.Builder<String, String>() .worker(w) .callback(w) .param("0") .build(); WorkerWrapper<String, String> workerWrapper1 = new WorkerWrapper.Builder<String, String>() .worker(w1) .callback(w1) .param("1") .depend(workerWrapper) .build(); WorkerWrapper<String, String> workerWrapper2 = new WorkerWrapper.Builder<String, String>() .worker(w2) .callback(w2) .param("2") .build(); long now = SystemClock.now(); System.out.println("begin-" + now); Async.beginWork(2500, workerWrapper, workerWrapper2); System.out.println("end-" + SystemClock.now()); System.err.println("cost-" + (SystemClock.now() - now)); Async.shutDown(); } /** * 0,2同时开启,1在0后面. 组超时,则0和2成功,1失败 * 0---1 * 2 */ private static void testMultiError() throws ExecutionException, InterruptedException { ParWorker w = new ParWorker(); ParWorker1 w1 = new ParWorker1(); ParWorker2 w2 = new ParWorker2(); WorkerWrapper<String, String> workerWrapper2 = new WorkerWrapper.Builder<String, String>() .worker(w2) .callback(w2) .param("2") .build(); WorkerWrapper<String, String> workerWrapper1 = new WorkerWrapper.Builder<String, String>() .worker(w1) .callback(w1) .param("1") .build(); WorkerWrapper<String, String> workerWrapper = new WorkerWrapper.Builder<String, String>() .worker(w) .callback(w) .param("0") .next(workerWrapper1) .build(); long now = SystemClock.now(); System.out.println("begin-" + now); Async.beginWork(1500, workerWrapper, workerWrapper2); System.out.println("end-" + SystemClock.now()); System.err.println("cost-" + (SystemClock.now() - now)); Async.shutDown(); } /** * 0执行完,同时1和2, 1\2都完成后3 * 1 * 0 3 * 2 */ private static void testMulti3() throws ExecutionException, InterruptedException { ParWorker w = new ParWorker(); ParWorker1 w1 = new ParWorker1(); ParWorker2 w2 = new ParWorker2(); ParWorker3 w3 = new ParWorker3(); WorkerWrapper<String, String> workerWrapper3 = new WorkerWrapper.Builder<String, String>() .worker(w3) .callback(w3) .param("3") .build(); WorkerWrapper<String, String> workerWrapper2 = new WorkerWrapper.Builder<String, String>() .worker(w2) .callback(w2) .param("2") .next(workerWrapper3) .build(); WorkerWrapper<String, String> workerWrapper1 = new WorkerWrapper.Builder<String, String>() .worker(w1) .callback(w1) .param("1") .next(workerWrapper3) .build(); WorkerWrapper<String, String> workerWrapper = new WorkerWrapper.Builder<String, String>() .worker(w) .callback(w) .param("0") .next(workerWrapper1, workerWrapper2) .build(); long now = SystemClock.now(); System.out.println("begin-" + now); Async.beginWork(3100, workerWrapper); // Async.beginWork(2100, workerWrapper); System.out.println("end-" + SystemClock.now()); System.err.println("cost-" + (SystemClock.now() - now)); System.out.println(Async.getThreadCount()); Async.shutDown(); } /** * 0执行完,同时1和2, 1\2都完成后3 * 1 * 0 3 * 2 */