Skip to main content
se eliminaron 7 caracteres en el cuerpo
Origen Enlace
ChemaCortes
  • 8.9k
  • 22
  • 36

Los futuros parecen un modo simple de lanzar hilos, pero su ejecución termina cuando se obtiene el resultado (promesa). A partir de entonces usará siempre el valor calculado, por lo que cualquier efecto colateral que hubiera hechohaga ya no se volverá a repetir.

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 finitofijo 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 servidorservido para responder a tu pregunta.

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.

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.

Los futuros parecen un modo simple de lanzar hilos, pero su ejecución termina cuando se obtiene el resultado (promesa). A partir de entonces usará siempre el valor calculado, por lo que cualquier efecto colateral que haga ya no se volverá a repetir.

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 fijo 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 servido para responder a tu pregunta.

Mínimos cambios en el código
Origen Enlace
ChemaCortes
  • 8.9k
  • 22
  • 36
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 BankMyApp 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.failed onFailureforeach {
      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}")

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

}
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 MyApp 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.failed foreach {
      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}")

}
Origen Enlace
ChemaCortes
  • 8.9k
  • 22
  • 36

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.