Package akka.transactor

Examples of akka.transactor.Atomically

26
27
28
29
30
31
32
33
34
35
36
        }
        failer = (TypedCounter) TypedActor.newInstance(TypedCounter.class, FailerImpl.class);
    }

    @Test public void incrementAllCountersWithSuccessfulTransaction() {
        Coordination.coordinate(true, new Atomically() {
            public void atomically() {
                for (TypedCounter counter : counters) {
                    counter.increment();
                }
            }
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
        }
    }

    @Test public void incrementNoCountersWithFailingTransaction() {
        try {
            Coordination.coordinate(true, new Atomically() {
                public void atomically() {
                    for (TypedCounter counter : counters) {
                        counter.increment();
                    }
                    failer.increment();
View Full Code Here
39
40
41
42
43
44
45
46
47
48
49
                final CountDownLatch latch = increment.getLatch();
                if (!friends.isEmpty()) {
                    Increment coordMessage = new Increment(friends.subList(1, friends.size()), latch);
                    friends.get(0).sendOneWay(coordinated.coordinate(coordMessage));
                }
                coordinated.atomic(new Atomically(txFactory) {
                    public void atomically() {
                        increment();
                        StmUtils.scheduleDeferredTask(new Runnable() {
                            public void run() { latch.countDown(); }
                        });
View Full Code Here
21
22
23
24
25
26
27
28
29
30
31
            if (message instanceof Increment) {
                Increment increment = (Increment) message;
                if (increment.hasFriend()) {
                    increment.getFriend().sendOneWay(coordinated.coordinate(new Increment()));
                }
                coordinated.atomic(new Atomically() {
                    public void atomically() {
                        increment();
                    }
                });
            }
View Full Code Here
TOP

Related Classes of akka.transactor.Atomically

  • akka.transactor.example.UntypedCoordinatedCounter
  • akka.transactor.test.TypedCoordinatedIncrementTest
  • akka.transactor.test.UntypedCoordinatedCounter
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.