|
final static CyclicBarrier barrier = new CyclicBarrier(40); //类似集合点的使用,循环屏障,等待X个线程到达后一起运行
/**---test 下增加以下-----**/
// try {
// barrier.await(3, TimeUnit.SECONDS); //等待3秒钟还没集合就超时,TimeUnit.SECONDS代表前面的参数为3秒的意思,同样还有TimeUnit.MILLISECONDS
// } catch (Exception e) {
// grinder.logger.error("在限定时间内没有等到需要集合的用户数:" + e);
// }
|