Java Synchronization Trouble

Question

Ich bin neu in Java und probierte die Synchronisation mit einem Beispielprogramm aus, um Nummern bis 100 mit MultiThreading hinzuzufügen. Und folgendes ist Code, den ich mir ausgedacht habe. Wenn ich den Code teste, gibt es manchmal den korrekten Wert von 4590, aber manchmal gibt es nicht den richtigen Wert. Kann jemand darauf hinweisen, was mache ich falsch

class Counter{ 
    Integer counter = 0; 

    public void increment(int i){ 
     synchronized (counter){ 
      counter += i; 
     } 
    } 
} 

class ObjectTest implements Runnable{ 

    int i; 
    Counter blah; 

    public ObjectTest(Counter counter,int i){ 
     blah =counter; 
     this.i = i; 
    } 
    @Override 
    public void run() { 
     blah.increment(i); 
    } 
} 

public class SyncTest { 

    public static void main(String args[]) throws InterruptedException { 
     ThreadPoolExecutor executor = new ThreadPoolExecutor(4,10,60, TimeUnit.SECONDS,new SynchronousQueue<Runnable>(), new ThreadPoolExecutor.CallerRunsPolicy()); 
     Counter counter = new Counter(); 
     for (int index = 0; index < 100; index++) { 
      ObjectTest objectTest = new ObjectTest(counter,index); 
      executor.execute(objectTest); 
     } 
     executor.shutdown(); 
     while (!executor.isTerminated()){ 
      Thread.sleep(1000L); 
     } 

     System.out.println(counter.counter); 
    } 
} 

Answer 1

können Sie nicht auf counter synchronisieren, weil es eine Integer ist, die unveränderlich ist. Daher erstellt counter += i ein neues Objekt Integer, das nicht das gleiche ist, das synchronisiert wurde.

Sie können es int counter machen und haben eine separate Object lock = new Object();, Synchronisierung auf lock.