Los futuros parecen un modo simple de lanzar hilos, pero su ejecución termina cuando obtiene el resultado (promesa). A partir de entonces usará siempre el valor calculado, por lo que cualquier efecto colateral que hubiera hecho ya no se volverá a repetir.
Por ejemplo:
val trans = Future {
println("Hola")
1
}
for {
i <- 1 to 10
x <- trans
} println(x)
El futuro trans
sólo imprime un único "Hola"
, aunque devuelve el valor 1
tantas veces como se requiere.
No existe una única forma de diseñar una aplicación para su ejecución concurrente y sería un tema demasiado amplio para exponer aquí. Cada aplicación concurrente requiere una solución diferente. Probablemente, este problema se solucione mejor con el modelo actor (librería akka
).
En nuestro caso, no es posible emular una transacción bancaria con futuros. Necesitamos un objeto que haga de Banco que opere con nuestras cuentas. En producción, esta labor sería realizada por una base de datos, un servicio web u otra entidad. En el ejemplo que pongo se emula con el objeto Banco
que controla los cambios de estado de las cuentas. Pongo el código y luego lo explico:
import scala.concurrent.{ Future, Await }
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.duration._
import scala.util.{ Success, Failure }
import scala.util.Random
trait Cuenta
case class CuentaAhorros(numero: String, idUser: String, saldo: BigDecimal) extends Cuenta
case object RaceConditionException extends Exception
object Banco {
var cuentaPrincipal = CuentaAhorros("021-123-456-11", "1067905803", 20)
def saldoActual = cuentaPrincipal.saldo
def buscarCuenta(numeroCuenta: String): Future[CuentaAhorros] = Future {
cuentaPrincipal
}
def consignar(cuenta: CuentaAhorros, nuevoSaldo: BigDecimal): Future[CuentaAhorros] = Future {
// Tiempo de espera aleatorio
Thread.sleep(10 * Random.nextInt(20))
// Si el saldo ha cambiado, rechazamos la operación
if (cuenta.saldo != saldoActual)
throw RaceConditionException
else
cuentaPrincipal = cuentaPrincipal.copy(saldo = nuevoSaldo)
cuentaPrincipal
}
}
object Bank extends App {
def transaccion(numCuenta: String, incSaldo: BigDecimal): Unit = {
val trans = for {
cuenta <- Banco.buscarCuenta("021-123-456-11")
nuevaCuenta <- Banco.consignar(cuenta, cuenta.saldo + incSaldo)
} yield nuevaCuenta
// Si falla la transacción, repetimos la operación
trans onFailure {
case RaceConditionException =>
println(f"No he podido terminar la transacción ($numCuenta,$incSaldo%8.2f). Reiniciando...")
transaccion(numCuenta, incSaldo)
}
}
for {
s <- 20 to 100 by 20
} transaccion("021-123-456-11", s)
Thread.sleep(1000)
println(s"Saldo final: ${Banco.saldoActual}")
}
He usado una técnica llamada CAS (check and swap). Cuando el objeto Banco
tiene que consolidar el saldo, chequea antes que el saldo con el que ha estado trabajado el proceso es idéntico al actual. En caso contrario rechaza la operación porque supone que otro proceso había modificado el saldo. El proceso que ve rechazada su operación, se reinicia y vuelve a empezar.
Podemos asegurar que este diseño para la transacción será una "operación atómica" (al menos uno de los procesos acabará en un número finito de pasos). Si ejecutamos el programa varias veces, veremos que algunos procesos aleatoramiente tendrán que reiniciar su proceso, pero al final todos ellos serán ejecutados y el saldo final siempre será el mismo. Seguramente no sea el modo más óptimizado de resolver este problema.
Espero que haya servidor para responder a tu pregunta.