private void startWorkers ( final ExecutorService executorService , final int numTasks ) { for ( int i = 0 ; i < numTasks ; i ++ ) { workerFutures . add ( executorService . submit ( new Callable < Void > ( ) { @ Override public Void call ( ) throws Exception { runWorkLoop ( ) ; return null ; } } ) ) ; } }
Start worker threads with a shared log .