Die Verwaltung von threads in Grails-Services

Also ich habe einen service eingerichtet importieren eine große Menge von Daten aus einer Datei, die der Benutzer hochlädt. Ich möchte die Benutzer in der Lage sein, weiter zu arbeiten auf der Website, während die Datei verarbeitet wird. Ich erreichte dies durch die Erstellung eines Threads.

Thread.start {
 //work done here
}

Nun entsteht das problem, dass ich wollen nicht zu haben, mehrere threads gleichzeitig laufen. Hier ist, was ich versucht habe:

class SomeService {

Thread thread = new Thread()

 def serviceMethod() {
   if (!thread?.isAlive()) {
     thread.start {
        //Do work here
     }
   }
 }

}

Aber das funktioniert nicht. thread.isAlive() immer false zurück. Irgendwelche Ideen auf, wie kann ich dies erreichen?

InformationsquelleAutor James Kleeh | 2013-05-30
  1. 16

    Ich würde überlegen, einen Executor statt.

    import java.util.concurrent.*
import javax.annotation.*

class SomeService {

ExecutorService executor = Executors.newSingleThreadExecutor()

 def serviceMethod() {
   executor.execute {
      //Do work here
   }
 }


 @PreDestroy
 void shutdown() {
   executor.shutdownNow()
 }

}

    Mit einem newSingleThreadExecutor wird sichergestellt, dass tasks eine nach der anderen. Wenn es ein hintergrund-task bereits ausgeführt wird dann die nächste Aufgabe wird sein, in eine Warteschlange gestellt, und gestartet wird, wenn der laufende task beendet hat (serviceMethod sich immer noch sofort wieder zurück).

    Möchten Sie vielleicht zu prüfen, die executor plugin, wenn Sie Ihre "Arbeit tun, hier" beinhaltet GORM Datenbank-Zugriff, wie das plugin den entsprechenden Persistenz-Kontext (z.B. Hibernate-session) für Ihre hintergrund-tasks.

    • Es bezieht mit GORM. Id wirklich lieber nicht zu installieren, ein plugin nur für diese. Kann ich dazu komme es zu benutzen?
    • mit withTransaction sollte es tun (zumindest wenn man auf den Ruhezustand, ich kann nicht sprechen für mongo), aber die executor plugin ist sehr leicht im Gewicht, so würde ich nicht entlassen Sie aus der hand.
    • Sie greifen konnten die entsprechenden Stücke, die Sie brauchen, in den source-code github.com/basejump/grails-executor/tree/master/src/groovy/.... Ich würde einfach das plugin verwenden, wenn ich Sie wäre, um zu vermeiden, Umgang mit potentiellen Persistenz Probleme...
    • Vielen Dank - ich eigentlich schon, hatte es, wenn ich mit den thread (duh).
    • Der plugin-Dokumentation sagt, es funktioniert nur mit JDK6. Ich benutzt den code, den Sie haben es in JDK7, ohne Frage. Ist das plugin Dokumentation alt oder ist es richtig?
    • angeschaut am plugin-code im detail in der Vergangenheit kann ich keinen Grund sehen, warum es nicht funktionieren sollte, auf 7, ich nehme "funktioniert nur auf 1.6" bedeuten "und nicht auf 1.5 oder früher".
    • Gotcha, vielen Dank

    InformationsquelleAutor Ian Roberts
  2. 2

    Einen anderen Weg, dies zu tun ist die Verwendung von Spring @Async annotation.

    Fügen Sie die folgenden resources.groovy:

    beans = {
    xmlns task:"http://www.springframework.org/schema/task"
    task.'annotation-driven'('proxy-target-class':true, 'mode':'proxy')
}

    Jede service-Methode, die Sie jetzt kommentieren mit @Async wird asynchron ausgeführt, z.B.

    @Async
def reallyLongRunningProcess() {
    //do some stuff that takes ages
}

    Wenn Sie möchten, dass nur ein thread zum ausführen der import-zu einer Zeit, Sie könnten so etwas tun -

    class MyService {
    boolean longProcessRunning = false

    @Async
    def reallyLongRunningProcess() {
        if (longProcessRunning) return

        try {
            longProcessRunning = true
            //do some stuff that takes ages
        } finally {
            longProcessRunning = false
        }
    }
}
    • Ich Schätze die Antwort, aber ich könnte eine variable mit einer Flagge in der Art, wie ich es Tat. Ich bevorzuge nur nicht, es zu tun auf diese Weise.
    InformationsquelleAutor rcgeorge23
Schreibe einen Kommentar