Wie gibt man einen Wert von einem Lambda-Ausdruck zurück?

Question

Ich habe eine Sammlung (concurrentHashMap) und ein Verfahren, das in einem separaten Thread und das Rück numOfApples funktionieren soll:

public int getApples(String treeNum) { 
    int numOfApples = null; 
    Runnable task =() -> {concurrentHashMap.get(treeNum).getApples(); }; 
    new Thread(task).start() ; 
    return numOfApples; 
} 

Ist es möglich, passieren num von Äpfeln aus Lambda-Ausdruck (concurrentHashMap.get(treeNum).getApples()) an die numOfApples Variable?

Answer 1

Das Problem besteht nicht darin, den Wert von einem Lambda-Ausdruck zurückzugeben. Es geht darum, ein Ergebnis von einer asynchronen Aufgabe zurückzugeben.

Mit einem Runnable können Sie das nicht so einfach tun. Sie sollten stattdessen einen Callable verwenden, der seinen Javadoc zitiert:

Eine Aufgabe, die ein Ergebnis zurückgibt und eine Ausnahme auslösen kann.

Auch you definitely should not be creating unmanaged raw threads like that: new Thread(task).start();. You should use an ExecutorService and submit the Callable to it.

Betrachten Sie den folgenden Code ein:

public int getApples(String treeNum) { 
    Callable<Integer> task =() -> concurrentHashMap.get(treeNum).getApples(); 
    Future<Integer> future = Executors.newCachedThreadPool().submit(task); 
    return future.get(); 
} 

Es schafft eine Callable<Integer> die Aufgabe, die die Zahl der Äpfel zurück. Diese Aufgabe wird an eine ExecutorService gesendet (ich habe hier einfach einen Cache-Thread-Pool verwendet, möglicherweise möchten Sie einen anderen). Das Ergebnis ist in einer Future<Integer> Instanz enthalten, deren get()-Methode blockiert, auf das Ergebnis wartet und es dann zurückgibt.