Ist es sicher, in einem Verschluss zu zünden?

Question

Ich arbeite einen gezündeten Service, der einige Aufgaben über run veröffentlichen wird. Der Service sieht so aus:

public interface MySvc{ 
    public void foSomeJob(); 
} 

public MySvcImpl implements MySvc, Service{ 

    @IgniteInstanceResource 
    private Ignite ignite; 

    public void foSomeJob(){ 
     IgniteCompute compute = ignite.compute(); 
     compute.run(() -> { 
      ignite.binary()   //<----Is it safe? 
        .builder("TYPE"); // What is gonna happen on another node 
      //build binary object and put it into a cache 
     } 
    } 
} 

Die Frage ist, was auf einem anderen Knoten geschehen wird? Wir serialisieren die Ignite Instanz (wirklich ??) und schickten es durch das Netzwerk. Oder wie funktioniert es?

In meinem Fall ist die Ausführung der Aufgabe kritisch ... Also würde ich gerne verstehen, wie es funktioniert, wenn die Aufgabe auf dem anderen Knoten ausgeführt wird?

Vielleicht sollte ich explizit Ignition.ignite(); verwenden?

Answer 1

Wenn Sie in Ihrem Fall Lambda verwenden, wird dieses entzündete Objekt serialisiert.

Stattdessen können Sie eine Klasse erstellen, um sie als Argument in compute() zu verwenden, und in dieser Klasse die Annotation @IgniteInstanceResource verwenden.

@IgniteInstanceResource-Annotation fügt eine aktuelle ignite-Instanz ein. Im Moment der Ausführung dieser Schließung haben Sie eine gezündete Instanz, die diese Schließung ausführt.

Answer 2

Ignite Die Instanz wird in der Tat "serialisiert", und auf dem entfernten Knoten erhalten Sie tatsächlich die Instanz, die für diesen Knoten lokal ist. Ignite wird natürlich nicht physisch über das Netzwerk gesendet.

Mit diesen Worten ist dieser Code korrekt und wird funktionieren. Die Verwendung von lambdas oder anonymen Klassen für Schließungen, die über das Netzwerk gesendet werden, ist jedoch keine sehr gute Übung. Ich würde empfehlen, eine separate Klasse zu erstellen und Ignite mit @IgniteInstanceResource oder Ignition.ignite() zu injizieren. Auf diese Weise haben Sie mehr Kontrolle darüber, was serialisiert und über das Netzwerk gesendet wird. Vom Leistungsstandpunkt aus ist es sicherer und besser.