packageThread.Abort;importjava.util.ArrayList;importjava.util.List;importjava.util.Random;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;importjava.util.concurrent.TimeUnit;//计数类

class Count {//DATA

private int count = 0;private Random rand = new Random(47);// public synchronized intincrement() {int temp =count;if(rand.nextBoolean())

Thread.yield();return (count = ++temp);

}public synchronized intvalue() {returncount;

}

}//动作类

class Entrance implementsRunnable {private static Count count = newCount();private static List entrances = new ArrayList();private int number = 0;private final intid;private static volatile boolean canceled = false;public static voidcancel() {

canceled= true;

}public Entrance(intid) {this.id =id;

entrances.add(this);

}

@Overridepublic voidrun() {while (!canceled) {synchronized (this) {++number;

}

System.out.println(this + " Total:" + count.increment());//要显示的数值都要通过同步方法读取才准确

try{

TimeUnit.MICROSECONDS.sleep(100);

}catch(Exception e) {

System.out.println("sleep interrupted");

}

}

System.out.println("Stopping " + this);

}public synchronized intgetValue() {returnnumber;

}publicString toString() {return "Entrance " + id + ": " +getValue();

}public static intgetTotalCount() {returncount.value();

}public static intsumEntrances() {int sum = 0;for(Entrance entrance : entrances) {

sum+=entrance.getValue();

}returnsum;

}

}public classOrnamentalGarden {public static void main(String[] args) throwsInterruptedException {

ExecutorService exec=Executors.newCachedThreadPool();for (int i = 0; i < 5; i++) {

exec.execute(newEntrance(i));

}

TimeUnit.SECONDS.sleep(3);

Entrance.cancel();

exec.shutdown();if (!exec.awaitTermination(250, TimeUnit.MILLISECONDS))

System.out.println("Some tasks were not terminated!");

System.out.println("Total:" +Entrance.getTotalCount());

System.out.println("Sum of Entrances:" +Entrance.sumEntrances());

}

}