Thread fest, wenn Java verwenden ConcurrentSkipListSet Methode hinzufügen

Question

Ich benutze ConcurrentSkipListSet-Sammlung, um mit gleichzeitigen Operator umzugehen. Ich finde es manchmal stecken, reproduct mit diesem Code:

import java.util.Comparator 
import java.util.concurrent._ 

object SetDeadLock extends App { 
    private val tasks = new ConcurrentSkipListSet[Task](new Comparator[Task](){ 
    override def compare(o1: Task, o2: Task): Int = { 
     val compare = (o1.systemTime - o2.systemTime).toInt 
     if (compare == 0) 1 else compare //distinct same time task 
    } 
    }) 

    for(i <- 1 to 20) { 
    tasks.add(Task()) 
    println(s"added - $i") 
    } 

    case class Task() { 
    val systemTime = System.currentTimeMillis() 
    } 
} 

Ausgabe

added - 1 
added - 2 

Es vielleicht an anderen stecken, dabei vor allem der Komparator benutzerdefinierte Sortier Daten Methode sind sie gleich (weil Set nicht unterstützen dasselbe Element) und alle Task ist neue Instanz, sollte es keinen Konflikt mit anderen sein.

mit jstack cmd, der Haupt-Thread stecken

at java.util.concurrent.ConcurrentSkipListMap.findPredecessor(ConcurrentSkipListMap.java:685) 

tut es ein Fehler war oder ich nur ein Prinzip irreführend?

Danke jede Hilfe oder Beratung.

UPDATE
Ich versuche gerade jetzt if (compare == 0) 1 else compare zu if (compare == 0) -1 else compare ändern, überraschend, arbeite ich gut!

Kann jemand klären, wie es funktioniert? Source-Code ist es schwierig für mich (und ich denke, dass viele Leute mir zustimmen), schließlich, jdk viele Arbeiten für die Maschine ausführen Geschwindigkeit nicht für Codeleser.

Schließlich
Um die peinliche Situation zu vermeiden, nur etwas anders Faktor comparator machen, welche Set ‚s Semantik übereinstimmen, wie eine zufällige value.but anhängt seine Ich denke, besser eine andere echte geeignete Sammlung zu finden sein.

Vor ein paar Tagen finde ich eine gute Idee, HashCode als zweite Überprüfung verwenden, wenn SystemTime gleich ist. hoffe hilfreich ~

Answer 1

Ihr Komparator ist nicht stabil. Ich glaube nicht, ConcurrentSkipListMap verspricht, sich gut zu verhalten, wenn verschiedene Aufrufe inkonsistente Ergebnisse geben. Zum Beispiel, je nachdem, wie Sie anrufen, können Sie sowohl eine < b und b < a gleichzeitig mit Ihrem Code denken.