importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;publicclassTest{publicstaticvoidmain(String[]args){//设置线程数ExecutorServiceservice=Executors.newFixedThreadPool(5);for(inti=0;i<10;i++){service.execute(newRunnableImpl(i));}service.shutdown();}privatestaticclassRunnableImplimplementsRunnable{privateintid;privateRunnableImpl(intid){this.id=id;}publicvoidrun(){System.out.println("开始执行"+id);try{Thread.sleep(2000);}catch(InterruptedExceptione){//nothingtodo}System.out.println(id+"执行完毕。");}@OverridepublicStringtoString(){return"线程"+id;}}}