Wie blockiere und entsperren Sie einen Servlet-Thread?

Question

Ich habe eine Feder @RestController, also eine einfache servlet.

Wenn das Servlet gleichzeitig mit den gleichen Werten aufgerufen wird (Benennung eines "Hash" in diesem Beispiel), möchte ich alle bis auf das erste Servlet blockieren. Und wenn dieser beendet ist, möchte ich die blockierten befreien.

Als eine Lösung dachte ich daran, den Hash zu einem ConcurrentHashMap hinzuzufügen, und auch die Servlet-Threads zu diesem hashmap als Wert für den Hash-Schlüssel hinzufügen.

Aber wie könnte ich dort einen laufenden Java-Thread hinzufügen?

Der folgende Pseudocode veranschaulicht, was ich versuche zu erreichen:

@RestController 
public class MyService { 
    //a map blocking any concurrent process on the same hash value 
    private ConcurrentHashMap<String, List<Object>> map; 

    @RequestMethod 
    public String myXmlMethod(Param params) { 
     String hash = params.getHash(); ////assume a value identifying a certain form of logic 

     if (!map.contains(hash)) { 
      //here no concurrent task is running, so block the hash until removal 
      map.put(hash, new ArrayList<Object>()); 
      callLongRunningTaskAndWriteToDB(); 

      List<Object> threads = map.get(hash); 
      map.remove(hash); //free the hash 

      //interrupt any waiting threads, as the hash completed now 
      if (threads != null && !threads.isEmpty()) { 
       for (thread : threads) { 
        thread.interruptWait(); 
       } 
      } 
     } else { 
      //this way the servlet thread cannot continue until the timout occurs, 
      //or the servlet thread is canceled by the main thread in the concurrent hashmap 
      thread = new Thread(this, Timeout.SECONDS(30)); 
      map.get(hash).add(thread); 
      waitForThreadTimeoutOrInterrupt(); 
     } 
    } 
} 

Frage: Aber wie kann ich eigentlich einen Griff des aktuellen „Faden“ des Verfahrens ausgeführt wird? Damit ich es zur Karte hinzufügen und darauf warten und unterbrechen kann?

Answer 1

Sie tun können, dass mit einer ConcurrentMap von FutureTask wie folgt:

Wir definieren zunächst die ConcurrentMap:

private final ConcurrentMap<String, FutureTask<MyResult>> map = new ConcurrentHashMap<>(); 

Wir die Logik implementieren, die zwei Threads zur gleichen Zeit, die die gleiche Aufgabe verhindert:

@RequestMethod 
public String myXmlMethod(Param params) { 
    String hash = params.getHash(); ////assume a value identifying a certain form of logic 
    FutureTask<MyResult> task = new FutureTask<>(new Callable<MyResult>() { 
     @Override 
     public MyResult call() throws Exception { 
      // My task here 
     } 
    }); 
    // This boolean means we are the first to insert the entry 
    boolean inserted = true; 
    try { 
     FutureTask<MyResult> previous = map.putIfAbsent(hash, task); 
     if (previous == null) { 
      // The task has not been defined so far so we execute it 
      task.run(); 
     } else { 
      // the task has already been defined 
      task = previous; 
      inserted = false; 
     } 
     // we wait until we get the result 
     return task.get(); 
    } finally { 
     // Clean up the per key map but only if our insertion succeeded and with our future 
     if (inserted) { 
      map.remove(hash, task); 
     } 
    } 
} 

Answer 2

Wenn Ihre Frage ist einfach, wie Sie den aktuellen Thread erhalten, können Sie den aktuellen Thread mit der statischen Methode currentThread der Klasse Thread erhalten.

Von javadoc:

Gibt einen Verweis auf den zur Zeit Thread Objekt ausgeführt wird.

Answer 3

Sie können den aktuellen Thread als Thread.currentThread zugreifen, wenn das Ihre Frage ist, aber ich sehe Sie versuchen, eine Art gegenseitigen Ausschluss für Ihre callLongRunningTaskAndWriteToDB() zu implementieren, so dass nur ein Thread wird diesen Code auszuführen.

Wird es nicht besser sein, einen Java-basierten Mechanismus wie java.util.concurrent.Semaphore zu verwenden? Noch mehr können Sie Ihre callLongRunningTaskAndWriteToDB Methode in einer Runnable Aufgabe gestellt, und der Zugang zu, dass durch Singleton bekommen und vergewissern Sie sich nur ein Thread die Methode ausführen ...