Início / coding / Perguntas / 78664391
Accepted
limestreetlab
Asked: 2024-06-25 03:54:28 +0800 CST

Como um Callable pode retornar um valor de um retorno de chamada void predefinido?

  • 772

Estou usando uma interface API relacionada a dados que possui uma função de retorno de chamada key void que é invocada automaticamente para marcar o fim de algumas operações de IO. Quero fazer a classe Callable<String>e usar Future<String> result.

Eu me esforço para descobrir como fazer o Callable retornar uma String. Fazer uma String returnResult(){return this.result}função para chamar internamente não funciona.

Por favor, avise.

Parece algo como:

public class MyCallable implements someAPIWrapper, Callable<String> {
    
    String result;

    @Override
    public void endOfJobCallback() { //predefined API callback marking end of work
      /*
      usually read the data and write to a file, but not my case.
      how to return this.result string from here?
      */
    }

    @Override
    public String call() throws Exception {
      //some logic stuff
      //make API call to request a bunch of data
      //inside a loop to listen to incoming messages, receiving and appending to the *result* variable
      //end of all messages signalled by the ending callback, stop loop and return result var
    }

}

class Main {
    public static void main(String[] args){
      MyCallable callable = new MyCallable();
      ExecutorService executor = Executors.newFixedThreadPool(2);
      Future<String> future = executor.submit(callable);
      String result = future.get(); //blocking until result ready
    }
}
java

2 respostas

  1. Best Answer

    Você pode usar um booleano (atômico) para saber quando parar o loop:

    public class MyCallable implements someAPIWrapper, Callable<String> {
    
    String result;
    private final AtomicBoolean complete = new AtomicBoolean();

    @Override
    public void endOfJobCallback() { //predefined API callback marking end of work
      complete.set(true); //set Boolean to true atomically so that the other method will know you have been called
    }

    @Override
    public String call() throws Exception {
      while (!complete.get()) {
        //Do your stuff
      }
      //if you reach this the callback was called
      return result;
    }

}

    Observação: não está claro exatamente como você ouve as mensagens porque você não adicionou nenhum código. Você pode querer pegar a ideia e adaptá-la ao código real, dependendo se você faz uma pesquisa curta, tem um webhook, etc.

    • 2

  2. Você poderia fazê-lo funcionar adicionando um CompletableFuturein MyCallablee completando-o em endOfJobCallback().

    public class MyCallable implements someAPIWrapper, Callable<String> {
    
    String result;
    CompletableFuture<String> future = new CompletableFuture<>();

    @Override
    public void endOfJobCallback() { //predefined API callback marking end of work
      future.complete(result);
    }
}

    e então no seu main():

    MyCallable callable = new MyCallable();
// do stuff with the API…

String result = callable.future.join(); //blocking until result ready

    (é claro que isso requer certeza de que endOfJobCallback()é chamado em 100% dos casos, caso contrário, você pode precisar implementar algum tratamento de erros ou pode querer usar get(timeout, unit)em vez de join())

    • 2

relate perguntas