ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [33/45] incubator-ignite git commit: sprint-1 - Changed default number of parallel jobs for collision SPIs.
Date Sun, 15 Feb 2015 03:12:24 GMT
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 <dsetrakyan@gridgain.com>
Authored: Sat Feb 14 05:19:11 2015 -0800
Committer: Dmitiry Setrakyan <dsetrakyan@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,


Mime
View raw message