Java API: coordinate that accepts an Atomic.
Java API: coordinate that accepts an Atomic.
For creating a coordination between typed actors that use
the Coordinated annotation.
Coordinated transactions will wait for all other transactions in the coordination
before committing. The timeout is specified by the default transaction factory.
Use the wait parameter to specify whether or not this coordinate block
waits for all of the transactions to complete.
Java API: coordinate that accepts an Atomically.
Java API: coordinate that accepts an Atomically.
For creating a coordination between typed actors that use
the Coordinated annotation.
Coordinated transactions will wait for all other transactions in the coordination
before committing. The timeout is specified by the default transaction factory.
Use the wait parameter to specify whether or not this coordinate block
waits for all of the transactions to complete.
For creating a coordination between typed actors that use the Coordinated annotation.
For creating a coordination between typed actors that use the Coordinated annotation. Coordinated transactions will wait for all other transactions in the coordination before committing. The timeout is specified by the default transaction factory.
For creating a coordination between typed actors that use the Coordinated annotation.
For creating a coordination between typed actors that use
the Coordinated annotation.
Coordinated transactions will wait for all other transactions in the coordination
before committing. The timeout is specified by the default transaction factory.
It's possible to specify whether or not this coordinate block waits for all of
the transactions to complete - the default is that it does.
Coordinating transactions between typed actors.
Example (in Scala)
trait Counter { @Coordinated def increment: Unit def get: Int } class CounterImpl extends TypedActor with Counter { val ref = Ref(0) def increment = ref alter (_ + 1) def get = ref.get } val counter1 = TypedActor.newInstance(classOf[Counter], classOf[CounterImpl]) val counter2 = TypedActor.newInstance(classOf[Counter], classOf[CounterImpl]) coordinate { counter1.increment counter2.increment }