功能需求：設備策略升級

詳細描述：用戶可以不定期的創建1條策略來升級選擇的多個設備從a版本到b版本???????????????????

解決方案 java代碼 創建個無界帶自動回收機制的線程池
ExecutorService threadPool = Executors.newCachedThreadPool(); 創建策略 //把每條策略要升級設備放入隊列中 LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<Integer>();
????for(int j=startNum;j<endNum;j++)
????{
?????queue.offer(dev[j]);
????} StratageConsumer consumer=new StratageConsumer(queue); 每次創建策略后加入線程池 threadPool.execute(consumer); 啟動策略 @Overridepublic void run() {Integer data=null;while(Thread.currentThread().isInterrupted()==false && isRunning){//System.out.println("運行線程數"+Thread.getAllStackTraces().size());try {//因為BlockingQueue是線程安全的，所以不用考慮同步問題data = queue.take();//升級處理if(data!=null){iCrawcomplete.update(data);}if(queue.isEmpty()){try {Thread.sleep(360*1000);} catch (Exception e) {} Thread.currentThread().interrupt(); isRunning = false; }Thread.sleep(60*1000);}catch (Exception e) {logger.info("抓取"+url+data+"出現異常"+e.getStackTrace());}}}

轉載于:https://www.cnblogs.com/4wei/archive/2012/12/24/2847263.html

總結

以上是生活随笔為你收集整理的一个多线程和队列的实例演示的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。