Java同步不起作用

Question

我試圖讓一個小程序來演示同步，但無論出於何種原因，這並不符合我的期望。重點是製作1000個線程，並讓它們全部爲靜態Integer對象「sum」加1。輸出應該是1000，但我得到不同的輸出。這就像addSum（）方法根本不同步。我試過拖延println，認爲它打印速度太快，但這不是問題。 我在這裏錯過了什麼？

public class sumsync implements Runnable { 
public static Integer sum = new Integer(0); 
public sumsync(){ 
} 

private synchronized void addSum(int i){ 
    sum += i; 
} 

@Override 
public void run() { 
    addSum(1); 
} 
} 

主要類：

public class sumsyncinit { 

private static final int max_threads = 1000; 

public static void main(String[] args) { 

sumsync task = new sumsync(); 
Thread thread; 

    for(int i=0; i<max_threads;i++){ 
     thread = new Thread(task); 
     thread.start(); 
    } 
    System.out.println(sumsync.sum); 
} 

} 

Answer 1

你是不是在等待你的線程來完成，因而沒有所有的增量已執行的保證。你基本上只是保證一次只有一個線程在addSum方法中。您可能需要使用Futures來等待結果。

Answer 2

使用ThreadPoolExecutor（http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/ThreadPoolExecutor.html）以先有一些統籌，而不是每次都創建一個新的線程，其次，調用爲了其awaitTermination打印方法，結果前等待所有線程終止。

實際上，在你的情況下，你還沒有設置一個機制來防止在所有線程完成它們的變量增量後發生打印執行。因此，打印結果可能是隨機的。awaitTermination在所有線程上充當join()並達到此要求。

此外，使變量volatile在這種情況下將是無用的和不安全的。

確實，​​關鍵字已經充當內存屏障和原子性，而易失性僅僅確保內存屏障。

此外，這裏的規則要記住，當一個人想做出一個變量volatile：

可以使用volatile變量，而不是隻鎖定下 組受限制的情況。爲了提供期望的線程安全性，以下兩個條件必須滿足volatile變量：
寫入變量不取決於其當前值。
變量不參與其他變量的不變量。

Answer 3

您還可以使sum爲AtomicInteger。

然後addSum()看起來如下。

public static AtomicInteger sum = new AtomicInteger(0); 

private void addSum(int i){ 
    sum.addAndGet(i); 
} 

UPDATE：溶液上僅旨在解決爭用條件。在Stephen的評論下面我發佈完整的解決方案，以便主線程在打印最終值之前等待其他線程完成。

import java.util.concurrent.CountDownLatch; 
import java.util.concurrent.atomic.AtomicInteger; 

public class sumsync implements Runnable { 
public static AtomicInteger sum = new AtomicInteger(0); 
private CountDownLatch latch; 
public sumsync(CountDownLatch latch){ 

    this.latch = latch; 
} 

private synchronized void addSum(int i){ 
    sum.addAndGet(i); 
} 

@Override 
public void run() { 
    addSum(1); 
    latch.countDown(); 
} 
} 

import java.util.concurrent.CountDownLatch; 

public class sumsyncinit { 

private static final int max_threads = 1000; 

public static void main(String[] args) { 

CountDownLatch latch = new CountDownLatch(max_threads); 

sumsync task = new sumsync(latch); 
Thread thread; 

    for(int i=0; i<max_threads;i++){ 
     thread = new Thread(task); 
     thread.start(); 
    } 
    try { 
     latch.await(); 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 
    System.out.println(sumsync.sum); 
} 

}