sprint-1 - Changed default number of parallel jobs for collision SPIs.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/c3557e4c Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/c3557e4c Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/c3557e4c Branch: refs/heads/ignite-sql-old Commit: c3557e4cf46726eac336ee846bd5fb033eb5d75b Parents: 188a18d Author: Dmitiry Setrakyan <dsetrak...@gridgain.com> Authored: Sat Feb 14 05:19:11 2015 -0800 Committer: Dmitiry Setrakyan <dsetrak...@gridgain.com> Committed: Sat Feb 14 05:19:43 2015 -0800 ---------------------------------------------------------------------- .../ignite/spi/collision/fifoqueue/FifoQueueCollisionSpi.java | 6 ++---- .../spi/collision/priorityqueue/PriorityQueueCollisionSpi.java | 6 ++---- 2 files changed, 4 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c3557e4c/modules/core/src/main/java/org/apache/ignite/spi/collision/fifoqueue/FifoQueueCollisionSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/collision/fifoqueue/FifoQueueCollisionSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/collision/fifoqueue/FifoQueueCollisionSpi.java index c520c11..ea2e791 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/collision/fifoqueue/FifoQueueCollisionSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/collision/fifoqueue/FifoQueueCollisionSpi.java @@ -74,11 +74,9 @@ import java.util.*; public class FifoQueueCollisionSpi extends IgniteSpiAdapter implements CollisionSpi, FifoQueueCollisionSpiMBean { /** - * Default number of parallel jobs allowed (value is {@code 95} which is - * slightly less same as default value of threads in the execution thread pool - * to allow some extra threads for system processing). + * Default number of parallel jobs allowed (set to number of cores times 2). */ - public static final int DFLT_PARALLEL_JOBS_NUM = 95; + public static final int DFLT_PARALLEL_JOBS_NUM = Runtime.getRuntime().availableProcessors() * 2; /** * Default waiting jobs number. If number of waiting jobs exceeds this number, http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c3557e4c/modules/core/src/main/java/org/apache/ignite/spi/collision/priorityqueue/PriorityQueueCollisionSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/collision/priorityqueue/PriorityQueueCollisionSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/collision/priorityqueue/PriorityQueueCollisionSpi.java index f17ed38..e423665 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/collision/priorityqueue/PriorityQueueCollisionSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/collision/priorityqueue/PriorityQueueCollisionSpi.java @@ -162,11 +162,9 @@ import java.util.*; public class PriorityQueueCollisionSpi extends IgniteSpiAdapter implements CollisionSpi, PriorityQueueCollisionSpiMBean { /** - * Default number of parallel jobs allowed (value is {@code 95} which is - * slightly less same as default value of threads in the execution thread pool - * to allow some extra threads for system processing). + * Default number of parallel jobs allowed (set to number of cores times 2). */ - public static final int DFLT_PARALLEL_JOBS_NUM = 95; + public static final int DFLT_PARALLEL_JOBS_NUM = Runtime.getRuntime().availableProcessors() * 2; /** * Default waiting jobs number. If number of waiting jobs exceed this number,
