commit 489aa9ba2351b66cd3a56a45f6bd5c664a6038f7
author Sho SHIMIZU <sshimizu@us.fujitsu.com> Thu Jan 14 17:19:32 2016 -0800
committer Gerrit Code Review <gerrit@onlab.us> Tue Jan 19 21:04:37 2016 +0000
tree 2813d376b13f43711327d28f8675dc291958e98e
parent 101417da64798ef67438783163f342a67c602851

Refactor: Use CompletableFuture instead of Executor#execute()

Change-Id: I97a155498e01c43d8adc83a55dbc2022732c862d

core/net/src/main/java/org/onosproject/net/intent/impl/IntentManager.java

diff --git a/core/net/src/main/java/org/onosproject/net/intent/impl/IntentManager.java b/core/net/src/main/java/org/onosproject/net/intent/impl/IntentManager.java
index f1d895b..77c0d9d 100644
--- a/core/net/src/main/java/org/onosproject/net/intent/impl/IntentManager.java
+++ b/core/net/src/main/java/org/onosproject/net/intent/impl/IntentManager.java
@@ -316,7 +316,7 @@
             log.trace("Execute operations: {}", operations);
 
             // batchExecutor is single-threaded, so only one batch is in flight at a time
-            batchExecutor.execute(() -> {
+            CompletableFuture.runAsync(() -> {
                 try {
                 /*
                  1. wrap each intentdata in a runnable and submit
@@ -350,7 +350,7 @@
 //            batchService.removeIntentOperations(data);
                 }
                 accumulator.ready();
-            });
+            }, batchExecutor);
         }
     }