this.threadNum=_threadNum;

cb=_cb;

preInit=new int[round];

for(int i=0;i<preInit.length;i++){

preInit[i]=r.nextInt(100);

}

}

 

abstract void sumValue();

/*

* 对long的操作是非原子的，原子操作只针对32位

* long是64位，底层操作的时候分2个32位读写，因此不是线程安全

*/

abstract long getValue();

 

public void testTime(){

ExecutorService se=Executors.newCachedThreadPool();

long start=System.nanoTime();

//同时开启2*ThreadNum个数的读写线程

for(int i=0;i<threadNum;i++){

se.execute(new Runnable(){

public void run() {

for(int i=0;i<round;i++){

sumValue();

}

 

//每个线程执行完同步方法后就等待

try {

cb.await();

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (BrokenBarrierException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

 

 

}

});

se.execute(new Runnable(){

public void run() {

 

getValue();

try {

//每个线程执行完同步方法后就等待

cb.await();

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (BrokenBarrierException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

 

}

});

}

 

try {

//当前统计线程也wait,所以CyclicBarrier的初始值是threadNum*2+1

cb.await();

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (BrokenBarrierException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

//所有线程执行完成之后，才会跑到这一步

long duration=System.nanoTime()-start;

out.println(id+" = "+duration);

 

}

 

}