先用python實現,把每一個要處理的參數存放到隊列Queue中,然后創(chuàng)建線程從隊列中取出classThreadExecuteJob(threading.Thread):"""ThreadedUrlGrab"""def__init__(self,queue):threading.Thread.__init__(self)self.queue=queuedefrun(self):while1:i=self.queue.get()try:print"執(zhí)行的參數"+str(i)#發(fā)送執(zhí)行完畢信號self.queue.task_done()exceptExceptionase:logging.warning(str(fun)+"---"+str(e.message)+"---"+str(e.args))defexecute_job_thread_pool(queue):""":paramqueue:隊列:paramarg:函數的參數:return:"""foriinxrange(6):t=ThreadExecuteJob(queue)t.setDaemon(True)t.start()if__name__=="__main__":importQueueday_q=Queue.Queue()foriinxrange(6):day_q.put(i)execute_job_thread_pool(day_q)day_q.join()用python實現的多線程取出0-5個數打印出來?，F在用java粗略實現的如下,但是隊列數據取完了主線程沒有停止,如何讓主線程停止,如何像python那樣隊列數據取完主線程也停止publicclassHelloJava8{publicstaticvoidmain(String[]args)throwsInterruptedException{//TODOAuto-generatedmethodstubBlockingQueues=newLinkedBlockingQueue();s.put("java");s.put("python");s.put("php");s.put("c++");s.put("c");ArrayListthreadList=newArrayList();Threadt1=newThread(newConsumer("zhangsan",s));t1.start();threadList.add(t1);Threadt2=newThread(newConsumer("lisi",s));t2.start();threadList.add(t2);Threadt3=newThread(newConsumer("wangwu",s));t3.start();threadList.add(t3);Threadt4=newThread(newConsumer("afei",s));t4.start();threadList.add(t4);Threadt5=newThread(newConsumer("jb",s));t5.start();threadList.add(t5);for(Threadthread:threadList){thread.join();}System.out.println("主線程執(zhí)行完畢");}}classConsumerimplementsRunnable{privateStringname;privateBlockingQueues=null;publicConsumer(Stringname,BlockingQueues){this.name=name;this.s=s;}publicvoidrun(){try{while(true){Stringproduct=(String)s.take();System.out.println(name+"消費("+product.toString()+").");System.out.println("===============");Thread.sleep(300);}}catch(InterruptedExceptione){e.printStackTrace();}}}