hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1674707 - /hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
Date Sun, 19 Apr 2015 23:35:10 GMT
Author: edwardyoon
Date: Sun Apr 19 23:35:09 2015
New Revision: 1674707

URL: http://svn.apache.org/r1674707
Log:
Use newCachedThreadPool

Modified:
    hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java

Modified: hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
URL: http://svn.apache.org/viewvc/hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java?rev=1674707&r1=1674706&r2=1674707&view=diff
==============================================================================
--- hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java (original)
+++ hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java Sun Apr 19 23:35:09
2015
@@ -241,9 +241,7 @@ public final class GraphJobRunner<V exte
     this.changedVertexCnt = 0;
     vertices.startSuperstep();
 
-    ExecutorService executor = Executors.newFixedThreadPool((peer
-        .getNumCurrentMessages() / conf.getInt(
-        "hama.graph.threadpool.percentage", 10)) + 1);
+    ExecutorService executor = Executors.newCachedThreadPool();
 
     while (currentMessage != null) {
       Runnable worker = new ComputeRunnable(vertices.get((V) currentMessage
@@ -282,9 +280,7 @@ public final class GraphJobRunner<V exte
     this.changedVertexCnt = 0;
     vertices.startSuperstep();
 
-    ExecutorService executor = Executors
-        .newFixedThreadPool((vertices.size() / conf.getInt(
-            "hama.graph.threadpool.percentage", 10)) + 1);
+    ExecutorService executor = Executors.newCachedThreadPool();
 
     for (Vertex<V, E, M> v : vertices.getValues()) {
       Runnable worker = new ComputeRunnable(v, null);
@@ -392,7 +388,7 @@ public final class GraphJobRunner<V exte
         .newInstance(conf.getClass(Constants.RUNTIME_PARTITION_RECORDCONVERTER,
             VertexInputReader.class));
 
-    ExecutorService executor = Executors.newFixedThreadPool(1000);
+    ExecutorService executor = Executors.newCachedThreadPool();
 
     try {
       KeyValuePair<Writable, Writable> next = null;



Mime
View raw message