使用线程池退出线程的无限循环

Question

我在使用多线程的代码中工作。相关代码的结构如下：

try { 
    ExecutorService threadExecutor = Executors.newFixedThreadPool(10); 

    while (resultSet.next()) { 
     name = resultSet.getString("hName"); 
     MyRunnable worker = new Myrunnable(name); 
     threadExecutor.execute(worker); 
     Counter++; 
    } 

    //This never appears 
    System.out.println("End while with counter" + Counter); 

    threadExecutor.shutdown(); 
    System.out.println("thread shutdown"); //this never appears 

    // Wait until all threads are finish 
    while (!threadExecutor.isTerminated()) { 
     threadExecutor.awaitTermination(1, TimeUnit.SECONDS); 
     System.out.println("inside the thread termination loop."); //I have infinite loop 

    } 

    System.out.println("Finished all threads"); //never appears 

} catch (Exception e) { 
    e.printStackTrace(); 
} 

System.out.println("END MAIN"); 

DBConnection.con.close(); 

运行函数肯定会结束。我的数据库中的姓氏执行所需的功能，并且其线程结束。

//The constructor 
MyRunnable (String name) { 
    this.name=name; 
} 

public void run() { 
    myclass Obj=new myclass(); 
    try { 
     Obj.myFunction(name); 
    } catch (Exception e) { 
     System.out.println("Got an Exception: "+e.getMessage()); 
    } 
    System.out.println(" thread exiting" + this.name); 
} 

我的问题是我的程序正确执行的一切只是在最后一个线程，我看到了“线程退出”从DB的姓氏。但是threadexecutor从不关闭，程序进入无限循环。

编辑

这里是主要的，它可以提取数据库名称的代码。

try { 
     st = DBConnection.con.createStatement(); 

     resultSet = st.executeQuery("select hName from schema1.table1 where checked=1 order by hName"); 

    } catch (Exception e) { 
     System.out.println("DB Error: " + e.getMessage()); 

    } 

Answer 1

这里是发生了什么事我最好的猜测：

首先，我怀疑，这两个意见：

//This never appears 
System.out.println("End while with counter" + Counter); 

threadExecutor.shutdown(); 
System.out.println("thread shutdown"); //this never appears 

是不正确的。我强烈怀疑，实际上你确实得到了这些消息，但他们混入了你的其他消息（如“线程退出”消息），所以你想念他们。

其次，我怀疑有时候，Obj.myfunction(name)挂起。如果Obj.myfunction涉及回写数据库，这很可能会发生 - 大多数情况下它都能正常工作，但是偶尔会发生（并且更可能使用更多行），您会遇到数据库死锁。所以，事实上，你没有得到的“线程退出”消息，每个名称，但找到列表中间的一个或两个不会给你这个消息将是困难的。

要确定是否属于这种情况，我会在坐在无限循环中时生成Java程序的线程转储。在Unix/Mac上，通过打开另一个窗口并执行kill -3 PID来完成此操作，其中PID是您的java进程的进程ID。在Windows中，我认为您需要使用的组合键是Ctrl-Break。在胎面转储中，查看线程池的工作线程是否卡在Obj.myfunction的调用中。

数据库死锁的一个可能的来源是，在程序结束时关闭数据库连接本身之前，您不要关闭ResultSet。我想你的while循环结束之后添加一个调用

resultSet.close(); 

，你打印出来之前你对"End while with counter"消息。如果即使在添加该语句后仍然发生数据库死锁，那么您将不得不问一个关于该功能myfunction正在做什么的不同问题。

Answer 2

您最后的评论更有意义：当您运行executor.execute(..)时，它并不意味着该线程将立即运行，即使它立即启动，它也不会打印“线程退出”消息，直到它完成。同时，主线程继续，并将：

• 打印System.out.println("End while with counter" + Counter);
• 运行的threadExecutor.shutdown();应返回几乎立即
• 打印System.out.println("thread shutdown");几乎立即太。

换句话说，如果你的线程正在做什么需要一点时间，那么在任何线程完成任务之前，这两行将被打印出来。

现在，如果你的程序不退出，这是最有可能的，因为已经评论的原因是什么Obj.myFunction(name)是干什么的， - 如果调用从来没有出于某种原因结束，你的结果集比你的线程池的大小更多的记录，while (!threadExecutor.isTerminated())循环将永远不会结束。