管理Java线程池及搭建分布式Hadoop调度框架

[java]代码库

package thread;
import java.util.Vector;
import java.util.concurrent.CountDownLatch;
public class MultiThread extends Thread {     
static Vector<Integer> 
list = new Vector<Integer>(100);     
static CountDownLatch count = new CountDownLatch(10);     
public void run() {          
while (list.size() > 0) {               
try {                    
int val = list.remove(0);                    
System.out.println(val);                    
Thread.sleep(100);//模拟处理               } 
catch (Exception e) {                    // 可能数组越界，这个地方只是为了说明问题，忽略错误               }          }                   
count.countDown(); // 删除成功减一     }     
public static void main(String[] args) throws InterruptedException {                   
for (int i = 0; i < 100; i++) {               
list.add(i);          }                   
long start = System.currentTimeMillis();          
for (int i = 0; i < 10; i++) {               
new MultiThread().start();          }                   
count.await();          
long end = System.currentTimeMillis();          
System.out.println("消耗 " + (end - start) + " ms");     }     // 消耗 1001 ms}//源代码片段来自云代码http://yuncode.net