ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sevdoki...@apache.org
Subject [31/50] [abbrv] incubator-ignite git commit: sprint-2: minor
Date Wed, 18 Feb 2015 10:41:26 GMT
sprint-2: minor


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/0dda33a3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/0dda33a3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/0dda33a3

Branch: refs/heads/ignite-223
Commit: 0dda33a309e5928362a4a165d39cb51979b06a0e
Parents: b3a5384
Author: Yakov Zhdanov <yzhdanov@gridgain.com>
Authored: Tue Feb 17 15:14:56 2015 +0300
Committer: Yakov Zhdanov <yzhdanov@gridgain.com>
Committed: Tue Feb 17 15:14:56 2015 +0300

----------------------------------------------------------------------
 .../datastructures/IgniteAtomicSequenceExample.java    | 13 ++++---------
 1 file changed, 4 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/0dda33a3/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java
b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java
index c65e2cd..f83a819 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java
@@ -21,8 +21,6 @@ import org.apache.ignite.*;
 import org.apache.ignite.examples.datagrid.*;
 import org.apache.ignite.lang.*;
 
-import java.util.*;
-
 /**
  * Demonstrates a simple usage of distributed atomic sequence.
  * <p>
@@ -47,18 +45,13 @@ public final class IgniteAtomicSequenceExample {
             System.out.println();
             System.out.println(">>> Cache atomic sequence example started.");
 
-            // Make name of sequence.
-            final String seqName = UUID.randomUUID().toString();
-
-            // Initialize atomic sequence.
-            IgniteAtomicSequence seq = ignite.atomicSequence(seqName, 0, true);
-
             // Try increment atomic sequence on all cluster nodes. Note that this node is
also part of the cluster.
-            ignite.compute().broadcast(new SequenceClosure(seqName));
+            ignite.compute().broadcast(new SequenceClosure("example-sequence"));
 
             System.out.println();
             System.out.println("Finished atomic sequence example...");
             System.out.println("Check all nodes for output (this node is also part of the
cluster).");
+            System.out.println();
         }
     }
 
@@ -78,6 +71,8 @@ public final class IgniteAtomicSequenceExample {
 
         /** {@inheritDoc} */
         @Override public void run() {
+            // Create sequence. Only one concurrent call will succeed in creation.
+            // Rest of the callers will get already created instance.
             IgniteAtomicSequence seq = Ignition.ignite().atomicSequence(seqName, 0, true);
 
             // First value of atomic sequence on this node.


Mime
View raw message