日期:2014-05-18  浏览次数:20771 次

急急急。。。在线等~~~java多线程的问题
本帖最后由 sarahsss 于 2013-07-07 18:12:15 编辑
有一个主线程main,每次从数据库中取1000条数据,分给5个线程(每个线程200条),进行数据分析。等待5个线程运行结束了,又取1000条,一次循环。代码如下:
	
public class WebPageAnalyzer implements Runnable{
        int start =0;int end = 0;int index = 0;
 public  DataDao da = DataDao.createDao();

 public static  List<Page> pageList;
 
.......
   public static void main(String[] args)
   {

pageList = wpa.da.getUnAnalysedPages();
if(pageList.size()>0)
{
System.out.println(new Date()+"  Found " + pageList.size() + " unanalynized pages.");
System.out.println("Start analysising for " +pageList.size() + " pages ...");
try {  
      ExecutorService executorService = Executors.newCachedThreadPool();  

      for (int i =0; i < 5; i++) {
        executorService.execute(new WebPageAnalyzer(i*200,Math.min((i+1)*200,pageList.size()),i+1)); 
        
        if((i+1)*200>pageList.size()){break;}
      }  

      executorService.shutdown();   
      
      while (!executorService.awaitTermination(60, TimeUnit.SECONDS)) { System.out.println("还有线程在忙活~~wait!!!!");} 
      System.out.println("Finished all threads"); 
    } catch (Exception e) {
     e.printStackTrace();
    }  
}
}

其中pagelist是静态变量,因为我认为5个线程只是读取pagelist的不同段的数据,并没有写入操作,所以没有同步。
程序在运行了3,4天以后,就出现了异常:每次取1000条,每个线程只分析了10几条就退出了,主线程又取1000条,每个线程又只分析了10几条,如此循环。但是日志文件中没有捕获到异常。 不知道是哪里出问题了。。。。求大神帮忙!~
Java