java.util.concurrent.CylicBarrier并发障碍器之多线程等待wait()

适用的业务场景：1）当需要开启多线程向数据库批量插入业务数据完成后；2）这些新插入的数据需要从数据库读取并重新处理（如：分配给其它业务员做跟进业务）；这些情况下，需要1）步完成，2）步才能执行查询。即：1）线程组未执行完时，2）任务会一直阻塞

一、开启多线程、等待线程，await()相当于等待设置的线程组完成后才执行相应操作

public class TestController extends BasicController {

    

    public static void main(String[] args) {

       try {

//将要开启的线程数量
int parties = 5;
CyclicBarrier barrier = null;
Map<String, Object> map = new HashMap<String,Object>();
map.put("a", 1);
for (int i = 0; i < parties; i++) {
if(i==0){
//当await的数量到达了设定的数量(parties)后，首先执行该Runnable(new TotalTask())对象。 
barrier = new CyclicBarrier(parties, new TotalTask());
}
//启动子线程
BillTask task = new BillTask(barrier,map);
task.start();
}
} catch (Exception e) {
e.printStackTrace();
}

    }

}

/**  

* 所有线程执行完后，执行该方法

*/  

class TotalTask implements Runnable {   

// private Object object;

// public TotalTask(Object object){

// this.object = object;

// }

   public void run() {  

      //业务逻辑操作

//   test(object);  
  System.out.println(Thread.currentThread().getName()+":设置的线程数执行完后，执行我");

   }   

} 

二、开启子线程

/**  

 * 子线程

 */  

public class BillTask extends Thread {   

    private CyclicBarrier barrier;     

    private Map<S
4000
tring, Object> map;

    //通过构造方法，传递需要处理的参数

    BillTask(CyclicBarrier barrier, Map<String, Object> map) {   

        this.barrier = barrier;   

        this.map = map;

    }     

    public void run() {   

        try {  

        //业务逻辑操作

        //customerService.updateCustomer(map);  

        System.out.println(Thread.currentThread().getName()+":"+map.get("a"));

            // 通知barrier已经完成，等待线程组

            barrier.await();   

        } catch (Exception e) {   

            e.printStackTrace();   

        }   

    }    

}