Method run

src/main/java/cms/component/topic/HotTopicComponent.java:203–229

()

		
		pool.execute(new Runnable(){   
            public void run() {  
            	while (threadActivity) { //如果系统关闭，则不再运行
                    try {  
                    	List<Long> data = new ArrayList<Long>();
                    	
                    	//每次到1000条数据才进行入库，或者等待1分钟，没达到1000条也继续入库
                    	drain(uniqueQueue, data, 1000, 10, TimeUnit.MINUTES);//第三个参数：数量; 第四个参数：时间; 第五个参数：时间单位
                	    
                    	for(Long l: data){
                    		uniqueQueue.deleteUnique(l);//删除唯一标记
                    	}
                    	
                	    saveHotTopic(data);
                	    
                    } catch (InterruptedException e) {  
                    //    e.printStackTrace();  
                        if (threadActivity && logger.isErrorEnabled()) {
				            logger.error("热门话题消费队列中断异常",e);
				        }
                    } catch (Exception e) {  
                    //    e.printStackTrace();  
                        if (logger.isErrorEnabled()) {
				            logger.error("热门话题消费队列错误",e);
				        }
                    }
                }
            }});
	}