You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@curator.apache.org by ra...@apache.org on 2017/02/09 18:36:01 UTC
[02/47] curator git commit: Use same thread executor
Use same thread executor
Project: http://git-wip-us.apache.org/repos/asf/curator/repo
Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/a5c460ca
Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/a5c460ca
Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/a5c460ca
Branch: refs/heads/CURATOR-3.0
Commit: a5c460caf67fdd1afe2eb1b0d639b87c7453c235
Parents: f732a40
Author: randgalt <ra...@apache.org>
Authored: Wed Jan 4 09:33:16 2017 -0500
Committer: randgalt <ra...@apache.org>
Committed: Wed Jan 4 09:33:16 2017 -0500
----------------------------------------------------------------------
.../src/main/java/org/apache/curator/x/crimps/Crimps.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/curator/blob/a5c460ca/curator-x-crimps/src/main/java/org/apache/curator/x/crimps/Crimps.java
----------------------------------------------------------------------
diff --git a/curator-x-crimps/src/main/java/org/apache/curator/x/crimps/Crimps.java b/curator-x-crimps/src/main/java/org/apache/curator/x/crimps/Crimps.java
index 52ff4a1..1e42ad6 100644
--- a/curator-x-crimps/src/main/java/org/apache/curator/x/crimps/Crimps.java
+++ b/curator-x-crimps/src/main/java/org/apache/curator/x/crimps/Crimps.java
@@ -1,5 +1,6 @@
package org.apache.curator.x.crimps;
+import com.google.common.util.concurrent.MoreExecutors;
import org.apache.curator.framework.api.BackgroundPathAndBytesable;
import org.apache.curator.framework.api.BackgroundPathable;
import org.apache.curator.framework.api.CuratorEvent;
@@ -9,7 +10,6 @@ import org.apache.zookeeper.data.Stat;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.Executor;
-import java.util.concurrent.ForkJoinPool;
import java.util.function.Function;
public class Crimps
@@ -86,7 +86,7 @@ public class Crimps
public static Crimps newCrimps()
{
- return new Crimps(ForkJoinPool.commonPool());
+ return new Crimps(MoreExecutors.sameThreadExecutor());
}
public static Crimps newCrimps(Executor executor)