package thread; import java.util.Vector; import java.util.concurrent.CountDownLatch; public class MultiThread extends Thread { static Vector list = new Vector(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