Promises and Futures, facilitando a programação assíncrona

O problema dessa abordagem, já clássico, é a maneira sincrona que resolvemos o problema. O usuário fica travado esperando a geração do pdf, além do disparo do email.  E se demorar demais e expirar o tempo de duração máximo de um request? Um outro problema é que pode acontecer algum problema na geração da apostila e o cliente, depois de ter esperado travado na tela por um tempo, recebe uma exception. Bem frustrante. A solução padrão seria deixar esse código rodar numa Thread separada. Abaixo segue:

Aqui eu já fui um pouco mais além e deixei o código de notificação via email dentro do próprio método run.  E esse é um outro problema que temos de atacar agora. A nossa Thread deveria apenas gerar o pdf, mandar email não é responsabilidade dela. Para esse tipo de processamento, onde devemos notificar alguém no final, o uso de Thread já começa a nos complicar. Podemos evoluir e tentar usar a API de Futures do próprio Java, que fica no pacote java.util.concurrent. Com ela, podemos rodar algum código de maneira assíncrona, pegar o retorno do processamento e fazer o que precisamos fazer. Abaixo segue o exemplo:

Um detalhe a se notar, é que o método get() vai travar a execução esperando o processamento assíncrono acabar para podermos continuar. O pior é que precisamos disso, pois o email só pode ser enviado após a geração da apostila.

Aí o problema fica mais complexo, encadear tarefas assíncronas, mesmo com a API de Futures do java fica complicado. Sem contar o tratamento de exception e a sintaxe pouco amigável para este tipo de construção. Para esse tipo de situação, a linguagem Scala, na versão 2.10, trouxe a API de Futures e Promises cujo objetivo é facilitar realização de trabalhos assíncronos. O código abaixo exige uma certa familiaridade com a linguagem Scala mas, o mais importante é a simplicidade atingida. Para mais indicações de como começar na linguagem, dê uma olhada nesse link. 

O retorno desse código é similar ao do código Java, porém o código para atingir o objetivo é muito mais simples. Agora caso queiramos encadear o retorno para outro processamento assíncrono, podemos fazer uso do método map. Cujo objetivo é o de pegar o retorno de uma Future e gerar outra. Abaixo segue um fluxo mostrando o upload das apostilas para a Amazon.

Agora podemos, quando acabar o upload, fazer o envio dos emails. O código final ficaria como abaixo:

Um último ponto que temos de tratar é que além de realizar o upload os pfds das apostilas, podemos enviar os outros formatos também. O único detalhe é que queremos vincular o envio do email ao término do envio do pdf. Para que, do meio de uma Future, possamos liberar outra para começar a executar, podemos usar a API de Promise. Como o próprio nome fala, você gera uma espécie de promessa que quando for cumprida vai liberar outra ponta para executar. Abaixo segue o exemplo:

Agora a outra Future do envio de email pode fazer uso dessa Promise  para começar o seu processamento.

Como Scala é uma linguagem muito poderosa, podemos usar ela em diversas partes do nosso sistema. Esse caso de processamento assíncrono simples é um ótimo caso. E caso queira, você pode criar uma classe Java apenas para servir de interface de uso com sua API em Scala. E aí, o que achou? Existe algum caso que você visualiza o uso dessa API para lhe ajudar?

Imagem da capa vem de http://astroneo.wordpress.com/