wie frei zu sperren, verwenden Sie zwei ConcurrentHashMap in Java/Scala?

Question

Ich Kopfschmerzen mit dem Problem vor langer Zeit, hoffe, einige Hilfe wirklich.
Ich möchte speichern viele Task mit ConcurrentSkipListMap welche innere ist ConcurrentHashMap als Multi-Segment-Sperre bekannt.
Die einfache Show Beispielcode mit scala (java auch lesbar):
val tasks = new ConcurrentSkipListMap[TaskKey, Task]() Klasse beziehen sich einfach wie:

class TaskKey(id: String, systemTime: Long)
TaskKey Klasse Identität Aufgabe ist weltweit einzigartig und die Aufgabe wie folgt:

trait Task { 
    val taskId: TaskKey //account and custom name 
    def execute(): Unit //do the task 
} 

Wenn ich TaskKey zum Betrieb meiner HashMap verwenden, ist Rost, aber eigentlich kann die HashMap mit ID kaum zugreifen.So muss ich eine andere ConcurrentHashMap definieren, um die Zuordnung von ID zu TaskKey zu speichern:
val auxiliaryMap = new ConcurrentHashMap[String, TaskKey]()
Lassen Sie uns ein Add betrachten und entfernen betreiben:

def get(taskId: String) = { 
    Option(auxiliaryMap.get(taskId)).flatMap{x => //try get TaskKey 
    //if TaskKey exist, try get it. 
    Option(tasks.get(x)) //make null to None 
    } 
} 

def remove(taskId: String) = { 
    Option(auxiliaryMap.remove(taskId)).flatMap{ x => //try get TaskKey 
    //if TaskKey exist, try remove it. 
    Option(tasks.remove(x)) //make null to None 
    } 
} 

Offensichtlich obwohl beide Map Thread-sicher ist, die Wrapper-Daten machen keine Konsistenz. Wenn ich eine Sperre verwende, wird die Karte mit mehreren Segmenten bedeutungslos. Wie kann ich mit dem Problem umgehen, dass zwei ConcurrentHashMap funktionieren?

Außerdem enthält die TaskKey eine Systemtime Variable verwendet, um Daten zu sortieren, komplett ConcurrentSkipListMap wie folgt definieren:

val tasks = new ConcurrentSkipListMap[TaskKey, Task](new Comparator[TaskKey]() { 
    override def compare(o1: TaskKey, o2: TaskKey): Int = { 
    val compare = (o1.systemTime - o2.systemTime).toInt 

    if (compare == 0) { 
     o1.hashCode() - o2.hashCode() 
    } else compare //distinct same time task 
    } 
}) 

jede mögliche Frage ist willkommen, wenn ich etwas zu verpassen.

Answer 1

Ich benutze Nachrichtenwarteschlange, um den Operator zu diesen maps.besides, muss dieser Weg keine Concurrenthashmap überhaupt, aber Nachrichtenwarteschlange möglicherweise eine gleichzeitige Warteschlange benötigen.