多线程排队执行

拼搏现实的明天。 2022-04-04 08:56 261阅读 0赞

10个线程A一起执行完，再一起执行20个线程B；然后再一起执行10个线程A，再一起执行20个线程B，如此往复50次。

public class CyclickBarrierTest {
        public static void main(String[] args) {
        	int childSize = 10;
        	int mainSize = 20;
        	int circleSize = 50;
            CyclicBarrier cbChild = new CyclicBarrier(childSize);
            CyclicBarrier cbMain = new CyclicBarrier(mainSize);
            ExecutorService esChild = Executors.newCachedThreadPool();
            ExecutorService esMain = Executors.newCachedThreadPool();
            for (int i = 0; i < circleSize; i++) {
                for (int j = 0; j < childSize; j++) {
                    try {
                        System.out.println("This is "+i+"st cycle, Thread cbChild" + j+" begin .... ");
                        esChild.execute(()->{try {
    						cbChild.await();
    					} catch (InterruptedException e) {
    						e.printStackTrace();
    					} catch (BrokenBarrierException e) {
    						e.printStackTrace();
    					}});
                        System.out.println("This is "+i+"st cycle, Thread cbChild" + j+" end .... ");
                        
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("cbChild.getParties()--------------------------" + cbChild.getParties());
                
                for (int j = 0; j < mainSize; j++) {
                    try {
                        System.out.println("This is "+i+"st cycle, Thread cbMain" + j+" end .... ");
                        esMain.execute(()->{try {
    						cbMain.await();
    					} catch (InterruptedException e) {
    						e.printStackTrace();
    					} catch (BrokenBarrierException e) {
    						e.printStackTrace();
    					}});
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    System.out.println("This is "+i+"st cycle, Thread cbMain" + j+" end .... ");
                }
                System.out.println("cbMain.getParties()--------------------------" + cbMain.getParties());
                
                System.out.println("=================================================================");
            }
            
            esChild.shutdown();
            esMain.shutdown();
    
        }
    }