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/38dee89a Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/38dee89a Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/38dee89a Branch: refs/heads/ignite-695 Commit: 38dee89ac53b30c6543e6d6c9cf909649f73efba Parents: 81ce0e6 Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Thu Apr 30 11:38:42 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Thu Apr 30 11:38:42 2015 +0300 ---------------------------------------------------------------------- .../internal/managers/communication/GridIoManager.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/38dee89a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java index 6d2046f..16d582b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java @@ -35,6 +35,7 @@ import org.apache.ignite.marshaller.*; import org.apache.ignite.plugin.extensions.communication.*; import org.apache.ignite.spi.*; import org.apache.ignite.spi.communication.*; +import org.apache.ignite.thread.*; import org.jetbrains.annotations.*; import org.jsr166.*; @@ -186,7 +187,12 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa mgmtPool = ctx.getManagementExecutorService(); utilityCachePool = ctx.utilityCachePool(); marshCachePool = ctx.marshallerCachePool(); - affPool = Executors.newFixedThreadPool(1); + affPool = new IgniteThreadPoolExecutor( + "aff-" + ctx.gridName(), + 1, + 1, + 0, + new LinkedBlockingQueue<Runnable>()); getSpi().setListener(commLsnr = new CommunicationListener<Serializable>() { @Override public void onMessage(UUID nodeId, Serializable msg, IgniteRunnable msgC) {
