1. launchTask
1 def launchTask( 2 context: ExecutorBackend, taskId: Long, taskName: String, serializedTask: ByteBuffer) { 3 val tr = new TaskRunner(context, taskId, taskName, serializedTask) 4 runningTasks.put(taskId, tr) 5 threadPool.execute(tr) 6 }
2.
原文：http://www.cnblogs.com/Torstan/p/4158671.html