0

Existe como fazer uma thread usando o flutter e retornar o resultado do processamento na tela?

Tenho o seguinte código. Na classe principal _MyHomePageState tenho o layout e a função _processo(). A idéia é iniciar a função _processo(), criar o IsolateRunner, o Runner vai chamar a função _processar, que vai fazer um procedimento e retornar, enquanto isso o usuário consegue acessar o app e chamar outras threads.

Meu problema está no retorno, pois não consigo exibir esse retorno na tela, por exemplo, já tentei retornar na variável status e diretamente na função _processo(). Pelo que entendi o retorno só poderia ocorrer uma vez, levando em conta que só são aceitas funções assíncronas.

Future<String> _processar(String foto) async {
   for (var i = 0; i < 10; i++) {
     sleep(const Duration(seconds:5)); 
     print('Thread - '+i.toString());
   }
   return 'Ok';
}

class _MyHomePageState extends State<MyHomePage> {
  Future<String> status;
  final String ass = 'asd';

 ..<código>..
   void _processo() async {
      final runner = await IsolateRunner.spawn();
      status = runner
           .run(_processar, 'foto')
           .whenComplete(() => (){
               runner.close();
               setState(() {
                   this.ass = status;
               });
      return this.status;
    });
   }
 ..<código>..
}
1
  • 1
    Porque que está a ser feito num isolate? Algum motivo em particular? 24/12/2018 às 11:07

1 Resposta 1

0

Esse código consegue fazer o que você está querendo, ele cria um Isolate e retorna uma resposta a cada vez que envia uma "foto"

static _processar(SendPort sendPort) async {
  // Cria a porta para receber a foto
  ReceivePort port = ReceivePort();

  // Envia a mensagem inicial para a main thread a porta criada
  sendPort.send(port.sendPort);

  // Espera receber a foto
  await for (var msg in port) {
    // Recebe a foto
    String foto = msg[0];
    // Local para retornar a resposta
    SendPort replyTo = msg[1];

    for (var i = 0; i < 10; i++) {
      sleep(const Duration(seconds:5));
      print('Thread - '+i.toString());
    }
    replyTo.send("ok");
  }
}

class _MyHomePageState extends State<MyHomePage> {
  Future<String> status;
  final String ass = 'asd';

  // Código

  void _processo() async {
    //Cria a porta para receber a mensagem inicial do isolate
    ReceivePort receivePort = ReceivePort();
    // Cria o isolate e envia a porta de recebimento
    await Isolate.spawn(_processar, receivePort.sendPort);

    // Guarda a porta do isolate para enviar a foto (Recebimento da mensagem inicial)
    SendPort sendPort = await receivePort.first;

    // Envia a foto
    String msg = await sendReceive(sendPort, "foto");

    setState(() {
      status = msg;
    });
  }
}

// Função para enviar a foto para o isolate junto com a porta da resposta
Future sendReceive(SendPort port, msg) {
  ReceivePort response = ReceivePort();
  port.send([msg, response.sendPort]);
  return response.first;
}

Espero ter ajudado!

Caso tenha alguma dúvida ou queira uma explicação mais detalhada tem esse artigo explicando mais detalhadamente: https://magrizo.wordpress.com/2018/12/28/como-usar-threads-no-flutter-com-a-biblioteca-isolate/

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .