necesita ayuda objeto de regresar en el método run hilo

Question

tengo una clase Java que se extiende Thread, que básicamente tiene el siguiente aspecto:

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() { 
     ... 
    } 
} 

necesito el método run() para devolver un ByteArrayOutputStream o una String. Sin embargo, como está en el método run() del Thread, no puedo establecer el tipo de devolución del método en ByteArrayOutputStream o String.

La clase HttpRequestDispatcher se llama dentro de una clase llamada OAuth.java.

¿Cómo puedo evitar esta situación?

Answer 1

Hay varias soluciones a este problema:

• Utilice una estructura de datos externo al hilo. Pase el objeto en su constructor y actualícelo cuando su tema esté por terminar.

• Utilice un método de devolución de llamada. Cuando termine el hilo, llame a la devolución de llamada.

• hacer uso de un java.util.concurrent.Future (Java> = 1,5):

  Un futuro representa el resultado de un cálculo asíncrono. Se proporcionan métodos para verificar si el cálculo está completo, para esperar su finalización y para recuperar el resultado del cálculo.

Answer 2

Let it implementar Callable<T> en lugar de Thread o Runnable. Aquí T debe representar el tipo de resultado. Use ExecutorService para ejecutarlo. Devolverá el resultado con el sabor de Future<V>.

Aquí hay un SSCCE con String como T, solo copie y pase.

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"; 
    } 
}