黑马程序员技术交流社区

标题: java多线程的问题 [打印本页]
作者: 丁永志    时间: 2013-7-14 19:22
标题: java多线程的问题
本帖最后由 杨兴庭 于 2013-7-15 17:58 编辑

有一个主线程main，每次从数据库中取1000条数据，分给5个线程（每个线程200条），进行数据分析。等待5个线程运行结束了，又取1000条，一次循环。代码如下：Java code
  1.         
  2. public class WebPageAnalyzer implements Runnable{
  3.         int start =0;int end = 0;int index = 0;
  4.          public  DataDao da = DataDao.createDao();
  5.         
  6.          public static  List<Page> pageList;
  7.                  
  8. .......
  9.    public static void main(String[] args)
  10.    {
  11.                         
  12.                                 pageList = wpa.da.getUnAnalysedPages();
  13.                                 if(pageList.size()>0)
  14.                                 {
  15.                                         System.out.println(new Date()+"  Found " + pageList.size() + " unanalynized pages.");
  16.                                         System.out.println("Start analysising for " +pageList.size() + " pages ...");
  17.                                         try {  
  18.                                               ExecutorService executorService = Executors.newCachedThreadPool();  

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

  26.                                               executorService.shutdown();   
  27.                                       
  28.                                               while (!executorService.awaitTermination(60, TimeUnit.SECONDS)) { System.out.println("还有线程在忙活～～wait!!!!");}
  29.                                               System.out.println("Finished all threads");
  30.                                             } catch (Exception e) {
  31.                                                     e.printStackTrace();
  32.                                             }  
  33.                                 }
  34. }
复制代码
其中pagelist是静态变量，因为我认为5个线程只是读取pagelist的不同段的数据，并没有写入操作，所以没有同步。
程序在运行了3，4天以后，就出现了异常：每次取1000条，每个线程只分析了10几条就退出了，主线程又取1000条，每个线程又只分析了10几条，如此循环。但是日志文件中没有捕获到异常。 不知道是哪里出问题了。

作者: 王海旺    时间: 2013-7-14 20:04
WebPageAnalyzer形参分别什么意思？
如楼主所说，是每条线程自己没有完成200条的分析任务的话，最好把分析逻辑代码贴出来，可能是那中间出现了条件中断，上面贴出来的代码只是接收分析任务的部分代码，无法准确判断原因。
作者: 诸隆隆    时间: 2013-7-14 22:29
楼主...写代码一点不假注释看起来真吃不消。读你的逻辑就不容易，再找逻辑中出错的很难的..



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2