Java-Multi Threading-Semaphor

Question

Die Zählervariable gibt nicht genau wieder, wie oft das Inkrement Methode aufgerufen wird. Warum nicht, und wie kann es behoben werden? (Sie müssen keinen Code schreiben, nur Englisch verwenden.)

Original:

import java.util.*; 
import java.lang.*; 
import java.io.*; 


class Foopadoop 
{ 
public static int counter = 0; 
public static void main(String[] args) throws Exception { 
    Runnable r = new Runnable() { 
     public void run() { 
      while(true){ 
       counter++; 
      } 
     } 
    }; 
    Thread t1 = new Thread(r); 
    Thread t2 = new Thread(r); 
    t1.start(); 
    t2.start(); 
} 
} 

Mine, Ich habe eine Semaphore, aber ich bin nicht sicher, ob ich es richtig mache oder ich bin nehme an, ein Schloss zu benutzen.

import java.util.*; 
import java.lang.*; 
import java.io.*; 
import java.util.concurrent.Semaphore; 

class Foopadoop 
{ 
public static int counter = 0; 
Semaphore lock = new Semaphore(0); 
public static void main(String[] args) throws Exception { 
    Runnable r = new Runnable() { 
     try{public void run() { 
      while(true){ 
       counter++; 
       lock.acquire(); 
      } 
     } 
     }finally{ 
     lock.release(); 
     } 
    }; 
    Thread t1 = new Thread(r); 
    Thread t2 = new Thread(r); 
    t1.start(); 
    t2.start(); 
} 
} 

Answer 1

Das ist nicht, wie man eine Semaphore verwenden.

Sie erwerben, bevor Sie die freigegebene Ressource zugreifen, und lassen Sie es nach:

while (true) { 
    try { 
    lock.acquire(); 
    counter++; 
    } finally { 
    lock.release(); 
    } 
} 

Da Sie acquire erste, müssen Sie auch mindestens 1 erlauben, sonst gibt es nichts zu acquire ist:

static Semaphore lock = new Semaphore(1); 

synchronized A-Block ist einfacher als ein Semaphore:

while (true) { 
    synchronized (Foopadoop.class) { 
    counter++; 
    } 
} 

oder Atomicinteger:

static AtomicInteger counter = new AtomicInteger(); 

// ... 

while (true) { 
    counter.getAndIncrement(); 
}