Benötigen

Question

Objekt in Fadenlauf Methode helfen Rückkehr ich eine Java-Klasse, die Thread erstreckt, sieht es im Grunde wie folgt aus:

public class HttpRequestDispatcher extends Thread { 
    private String url; 
    private String method; // GET or POST 
    private byte[] postData; 

    public HttpRequestDispatcher(String url, String method, byte[] postData) { 
     this.url = url; 
     this.method = method; 
     this.postData = postData; 
    } 

    public HttpRequestDispatcher(String url, String method) { 
     this.url = url; 
     this.method = method; 
    } 

    public void run() { 
     ... 
    } 
} 

Ich brauche die run() Methode ein ByteArrayOutputStream oder ein String zurückzukehren. Da es sich jedoch in der run()-Methode der Thread befindet, kann ich den Rückgabetyp der Methode nicht auf ByteArrayOutputStream oder String festlegen. Die Klasse HttpRequestDispatcher wird innerhalb einer Klasse namens OAuth.java aufgerufen.

Wie kann ich diese Situation umgehen?

Answer 1

Es gibt mehrere Lösungen für dieses Problem:

• externen eine Datenstruktur Verwenden Sie zum Thema. Übergeben Sie das Objekt in Ihrem Konstruktor und aktualisieren Sie es, wenn der Thread kurz vor dem Abschluss steht.

• Verwenden Sie eine Rückrufmethode. Wenn Ihr Thread fertig ist, rufen Sie den Rückruf an.

• Verwenden Sie eine java.util.concurrent.Future (Java> = 1.5):

  Eine Zukunft das Ergebnis einer asynchronen Berechnung darstellt. Es werden Methoden bereitgestellt, um zu überprüfen, ob die Berechnung abgeschlossen ist, auf ihre Beendigung zu warten und das Ergebnis der Berechnung abzurufen.

Answer 2

es Callable<T> statt Thread oder Runnable Lassen Sie implementieren. Hier muss T den Typ des Ergebnisses darstellen. Verwenden Sie ExecutorService, um es auszuführen. Es wird das Ergebnis im Geschmack eines Future<V> zurückgeben.

Hier ist ein SSCCE mit String als T, nur copy'n'paste'n'run es.

package com.stackoverflow.q2300433; 

import java.util.Arrays; 
import java.util.List; 
import java.util.concurrent.Callable; 
import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 
import java.util.concurrent.Future; 

public class Test { 
    public static void main(String... args) throws Exception { 
     ExecutorService executor = Executors.newSingleThreadExecutor(); 
     Future<String> future = executor.submit(new Task()); 
     System.out.println(future.get()); // Prints "result" after 2 secs. 

     // Or if you have multiple tasks. 
     // List<Future<String>> futures = executor.invokeAll(Arrays.asList(new Task())); 
     // for (Future<String> future : futures) { 
     //  System.out.println(future.get()); 
     // } 

     executor.shutdown(); // Important! 
    } 
} 

class Task implements Callable<String> { 
    public String call() throws Exception { 
     Thread.sleep(2000); 
     return "result"; 
    } 
}