public class TestRaceCondition implements Runnable{
public static int counter = 0;
public static void main(String[] args) {
List<Thread> threads = new ArrayList<>();
//產生threads，加入ArrayList
for( int i=0 ; i < 10 ; i++) {
TestRaceCondition runnable = new TestRaceCondition();
Thread t1 = new Thread(runnable,"T"+i);
threads.add(t1);
}
//一起發動所有的thread
for (Thread thread : threads) {
thread.start();
}
try {
//main thread 等待所有執行緒結束
for (Thread thread : threads) {
thread.join();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
//印出最後的值
System.out.println("finally counter = "+counter);
}
@Override
public void run() {
for ( int i= 0 ; i < 1000 ;i ++){
incrementCounter();
}
}
public static void incrementCounter(){
counter = counter + 1;
}
}[原始程式架構]
設立10個執行序塞入List中，再同時執行程序，各自生成一個Runnable的物件，執行run()，再incrementCounter()
此處會有共搶的Race Condtion發生，避免此狀況，可使用synchronized管控程序
(%所有synchronized標的都需唯一)
1. static 方法 加上 synchronized
所有用到這個方法的都是受到管控的，鎖頭為類別自身(TestRaceCondition.class)
public static synchronized void incrementCounter(){
counter = counter + 1;
}2.方法中設立專鎖物件控管執行方法
//設立專鎖物件
public final static Object locker = new Object(); @Override
public void run() {
for ( int i= 0 ; i < 1000 ;i ++){
synchronized (TestRaceCondition.locker)
incrementCounter();
}
}
3. 一般方法中加上 synchronized
所有用到這個方法的都是受到管控的，鎖頭為自身物件()
但此處每個Thread都各自生成物件執行程式，所以不具管控性，需調整程式為 => 生成一個執行物件，所有程序都使用同一物件
public static void main(String[] args) {
.
.
List<Thread> threads = new ArrayList<>();
TestRaceCondition runnable = new TestRaceCondition();
for( int i=0 ; i < 10 ; i++) {
Thread t1 = new Thread(runnable,"T"+i);
threads.add(t1);
.
.
@Override
public synchronized void run() {
for ( int i= 0 ; i < 1000 ;i ++){
incrementCounter();
}
}