ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [30/50] [abbrv] incubator-ignite git commit: GG-9141 - Added @IgniteAsyncSupported annotation.
Date Tue, 23 Dec 2014 00:00:04 GMT
GG-9141 - Added @IgniteAsyncSupported annotation.


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

Branch: refs/heads/master
Commit: 8165736fe1937055e8a3e4215d3e5fe5e1d27cca
Parents: a1a5b39
Author: Alexey Goncharuk <agoncharuk@gridgain.com>
Authored: Fri Dec 19 18:37:22 2014 -0800
Committer: Alexey Goncharuk <agoncharuk@gridgain.com>
Committed: Fri Dec 19 18:37:22 2014 -0800

----------------------------------------------------------------------
 .../java/org/apache/ignite/IgniteCompute.java   | 16 +++++++++++
 .../ignite/lang/IgniteAsyncSupported.java       | 28 ++++++++++++++++++++
 .../apache/ignite/transactions/IgniteTx.java    |  2 ++
 3 files changed, 46 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8165736f/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java b/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
index 16da89f..dc77698 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
@@ -119,6 +119,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @see ComputeJobContext#affinityKey()
      * @throws IgniteCheckedException If job failed.
      */
+    @IgniteAsyncSupported
     public void affinityRun(@Nullable String cacheName, Object affKey, Runnable job) throws
IgniteCheckedException;
 
     /**
@@ -135,6 +136,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @see ComputeJobContext#cacheName()
      * @see ComputeJobContext#affinityKey()
      */
+    @IgniteAsyncSupported
     public <R> R affinityCall(@Nullable String cacheName, Object affKey, Callable<R>
job) throws IgniteCheckedException;
 
     /**
@@ -150,6 +152,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @return Task result.
      * @throws IgniteCheckedException If task failed.
      */
+    @IgniteAsyncSupported
     public <T, R> R execute(Class<? extends ComputeTask<T, R>> taskCls,
@Nullable T arg) throws IgniteCheckedException;
 
     /**
@@ -165,6 +168,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @return Task result.
      * @throws IgniteCheckedException If task failed.
      */
+    @IgniteAsyncSupported
     public <T, R> R execute(ComputeTask<T, R> task, @Nullable T arg) throws IgniteCheckedException;
 
     /**
@@ -182,6 +186,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @throws IgniteCheckedException If task failed.
      * @see ComputeTask for information about task execution.
      */
+    @IgniteAsyncSupported
     public <T, R> R execute(String taskName, @Nullable T arg) throws IgniteCheckedException;
 
     /**
@@ -192,6 +197,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @param job Job to broadcast to all projection nodes.
      * @throws IgniteCheckedException If job failed.
      */
+    @IgniteAsyncSupported
     public void broadcast(Runnable job) throws IgniteCheckedException;
 
     /**
@@ -204,6 +210,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @return Collection of results for this execution.
      * @throws IgniteCheckedException If execution failed.
      */
+    @IgniteAsyncSupported
     public <R> Collection<R> broadcast(Callable<R> job) throws IgniteCheckedException;
 
     /**
@@ -218,6 +225,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @return Collection of results for this execution.
      * @throws IgniteCheckedException If execution failed.
      */
+    @IgniteAsyncSupported
     public <R, T> Collection<R> broadcast(IgniteClosure<T, R> job, @Nullable
T arg) throws IgniteCheckedException;
 
     /**
@@ -228,6 +236,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @param job Job closure to execute.
      * @throws IgniteCheckedException If execution failed.
      */
+    @IgniteAsyncSupported
     public void run(Runnable job) throws IgniteCheckedException;
 
     /**
@@ -238,6 +247,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @param jobs Collection of jobs to execute.
      * @throws IgniteCheckedException If execution failed.
      */
+    @IgniteAsyncSupported
     public void run(Collection<? extends Runnable> jobs) throws IgniteCheckedException;
 
     /**
@@ -250,6 +260,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @return Job result.
      * @throws IgniteCheckedException If execution failed.
      */
+    @IgniteAsyncSupported
     public <R> R call(Callable<R> job) throws IgniteCheckedException;
 
     /**
@@ -262,6 +273,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @return Collection of job results for this execution.
      * @throws IgniteCheckedException If execution failed.
      */
+    @IgniteAsyncSupported
     public <R> Collection<R> call(Collection<? extends Callable<R>>
jobs) throws IgniteCheckedException;
 
     /**
@@ -275,6 +287,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @return Future with reduced job result for this execution.
      * @throws IgniteCheckedException If execution failed.
      */
+    @IgniteAsyncSupported
     public <R1, R2> R2 call(Collection<? extends Callable<R1>> jobs, IgniteReducer<R1,
R2> rdc) throws IgniteCheckedException;
 
     /**
@@ -289,6 +302,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @return Job result.
      * @throws IgniteCheckedException If execution failed.
      */
+    @IgniteAsyncSupported
     public <R, T> R apply(IgniteClosure<T, R> job, @Nullable T arg) throws IgniteCheckedException;
 
     /**
@@ -303,6 +317,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @return Collection of job results.
      * @throws IgniteCheckedException If execution failed.
      */
+    @IgniteAsyncSupported
     public <T, R> Collection<R> apply(IgniteClosure<T, R> job, Collection<?
extends T> args) throws IgniteCheckedException;
 
     /**
@@ -319,6 +334,7 @@ public interface IgniteCompute extends IgniteAsyncSupport {
      * @return Future with reduced job result for this execution.
      * @throws IgniteCheckedException If execution failed.
      */
+    @IgniteAsyncSupported
     public <R1, R2, T> R2 apply(IgniteClosure<T, R1> job, Collection<? extends
T> args,
         IgniteReducer<R1, R2> rdc) throws IgniteCheckedException;
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8165736f/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java
new file mode 100644
index 0000000..828efdc
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/lang/IgniteAsyncSupported.java
@@ -0,0 +1,28 @@
+/* @java.file.header */
+
+/*  _________        _____ __________________        _____
+ *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
+ *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
+ *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
+ *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
+ */
+
+package org.apache.ignite.lang;
+
+import java.lang.annotation.*;
+
+/**
+ * Annotation to indicate that method can be executed asynchronously if async mode is enabled.
+ * To enable async mode, invoke {@link IgniteAsyncSupport#enableAsync()} method on the API.
+ * The future for the async method can be retrieved via {@link IgniteAsyncSupport#future()}
method
+ * right after the execution of an asynchronous method.
+ *
+ * TODO coding example.
+ *
+ * @see IgniteAsyncSupport
+ */
+@Documented
+@Target(ElementType.METHOD)
+public @interface IgniteAsyncSupported {
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8165736f/modules/core/src/main/java/org/apache/ignite/transactions/IgniteTx.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/IgniteTx.java b/modules/core/src/main/java/org/apache/ignite/transactions/IgniteTx.java
index c3466f7..97a0210 100644
--- a/modules/core/src/main/java/org/apache/ignite/transactions/IgniteTx.java
+++ b/modules/core/src/main/java/org/apache/ignite/transactions/IgniteTx.java
@@ -219,6 +219,7 @@ public interface IgniteTx extends GridMetadataAware, AutoCloseable {
      *
      * @throws IgniteCheckedException If commit failed.
      */
+    @IgniteAsyncSupported
     public void commit() throws IgniteCheckedException;
 
     /**
@@ -240,5 +241,6 @@ public interface IgniteTx extends GridMetadataAware, AutoCloseable {
      *
      * @throws IgniteCheckedException If rollback failed.
      */
+    @IgniteAsyncSupported
     public void rollback() throws IgniteCheckedException;
 }


Mime
View raw message