Java-Thread-Safe-Zähler

Lerne ich schreiben-thread-safe-Programme und wie bewerten Sie codes, die nicht threadsicher sind.

Einer Klasse wird als thread-sicher, wenn es richtig funktioniert, wenn die Ausführung durch mehrere threads.

Meine Counter.java ist nicht thread-sicher ist, aber die Ausgabe war gedruckt, wie erwartet von 0-9 für alle 3 threads.

Kann jemand erklärt warum? und wie thread-Sicherheit funktioniert?

public class Counter {

    private int count = 0;

    public void increment() {
        count++;
    }

    public void decrement() {
        count--;
    }

    public void print() {
        System.out.println(count);
    }

}

public class CountThread extends Thread {
    private Counter counter = new Counter();

    public CountThread(String name) {
        super(name);
    }

    public void run() {
        for (int i=0; i<10; i++) {
            System.out.print("Thread " + getName() + " ");
            counter.print();
            counter.increment();
        }
    }

}

public class CounterMain {

    public static void main(String[] args) {
        CountThread threadOne = new CountThread("1");
        CountThread threadTwo = new CountThread("2");
        CountThread threadThree = new CountThread("3");

        threadOne.start();
        threadTwo.start();
        threadThree.start();
    }

}
  • Sie sind mit einem anderen Counter-Objekt in jedem thread so, dass ist der Grund, warum sieht man keine thread-Sicherheit Probleme in diesem Fall.
InformationsquelleAutor ilovetolearn | 2013-04-06
  1. 5

    Dein code läuft wunderbar in Ihre spezifischen test. Das bedeutet nicht, es wird immer funktionieren. Versuchen Sie Durchlaufen ein sehr viel mehr Zeiten, und Sie werden wahrscheinlich beginnen zu sehen, Anomalien.

    Ihrem test ist ein bisschen so, wie wenn du getestet, dass eine Brücke unterstützen können 20 LKW bei der Fahrt auf der Brücke mit einem Auto. Ist es nicht etwas demonstrieren. Und die belegen, dass th-code thread-safe " mit einem test, ist fast unmöglich. Nur eine sorgfältige Lektüre und Verständnis für alle möglichen Probleme kann Ihnen garantieren, dass. Ein non-thread-safe-Programm gut funktioniert seit Jahren und habe plötzlich einen Fehler.

    Machen, die Sie gegen sicher, verwenden Sie ein AtomicInteger.

    EDIT :

    Auch, wie bereits von @SpringRush, Sie sind nicht gemeinsam auf einem einzigen Zähler zwischen threads. Jeder thread hat seinen eigenen Zähler. Also dein code ist eigentlich thread-safe ist, aber ich glaube nicht, dass es das tut, was Sie beabsichtigen, es zu tun.

    • Ja, ich sah, dass erst nachdem ich gepostet die erste version meiner Antwort. Ich reparierte es.
    • In anderen Worten, alle Variablen, die innerhalb jeder Thread wird nicht betroffen sein?
    • Thread-Sicherheit Probleme, die nur auftreten, wenn einige Staat ist geteilt zwischen mehreren threads. Wenn einige Zustand ist nur sichtbar und berührt von einem thread, hast du keine thread-Sicherheit problem, mit diesem Staat.
    • Ok. das ist eine ungültige Beispiel, das ich schrieb.
    InformationsquelleAutor JB Nizet
  2. 9

    Ihre Counter ist nicht geteilt durch die 3 threads statt, jeder thread hat eine einzigartige Counter

    • Vielleicht sollten Sie erklären warum das ist der Fall für eine ausführliche Antwort.
    • Die (offensichtliche und daher weggelassen) Erklärung, dass der OP erstellt eine eindeutige Zähler-Instanz in jedem Thread.
    • Ich Folge der Argumentation, natürlich. Ich wusste nur nicht, ob der Autor verstanden hat, wie seine Platzierung an der Theke Instanz machte es bestimmten Thread. (+1, nehme ich an.)
    InformationsquelleAutor BlackJoker
  3. 2

    So, dass eigentlich thread-safe. Für jeden CountThread, da gibt es einen Zähler. Um es nicht thread-sicher, ändern die Zähler-variable:

    private static Counter counter = new Counter();

    Dann wäre es nicht thread-sicher, da verschiedene threads könnte sein, ändern Sie den Zählerstand bei der gleichen Zeit.

    InformationsquelleAutor rongenre
  4. 1

    Versuchen Sie es mit diesem:

    public class ThreadSafeCounter {

    AtomicInteger value = new AtomicInteger(0);

public ThreadSafeCounter(AtomicInteger value) {
    this.value = value;
}

public void increment() {
    value.incrementAndGet();
}

public void decrement() {
    value.decrementAndGet();
}

public AtomicInteger getValue() {
    return value;
}

    }

    InformationsquelleAutor Laura Liparulo
Schreibe einen Kommentar