/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 7143

use a shared ExecutorService for replicate() calls.
https://redmine.dataone.org/issues/2623

         protected static final String RESOURCE_NODE = "node";
         protected static final String RESOURCE_ERROR = "error";
         protected static final String RESOURCE_META_CHANGED = "dirtySystemMetadata";
         // shared executor
     	private static ExecutorService executor = null;
     	static {
     		// use a shared executor service with nThreads == one less than available processors
         	int availableProcessors = Runtime.getRuntime().availableProcessors();
             int nThreads = availableProcessors * 1;
             nThreads--;
         	executor = Executors.newFixedThreadPool(nThreads);
+    	}
         /**
          * Initializes new instance by setting servlet context,request and response
          * */
-...
+    				}
+    			}
         	};
         	ExecutorService executor = Executors.newSingleThreadExecutor();
         	executor.execute(runner);
         	executor.shutdown();
         	// submit the task, and that's it
         	executor.submit(runner);
         	// thread was started, so we return success
             response.setStatus(200);

Also available in: Unified diff