程序在多线程中不能顺利结束

Question

我正在我的程序中创建一些线程。这里我使用了join方法，这样主线程就会等待我的所有线程。但是每当我运行这个程序的时候，它并没有完成，所有的信息消息都被打印出来，但是程序仍然没有顺利结束。有没有人能帮我解决这个问题呢？

下面是我的代码：

ArrayList<DeployerThread> threadsarrforjoin = new ArrayList<DeployerThread>();

for (int i = 0; i < serverList.size(); i++) {
    logger.debug("Inside for loop of buildParameterList()");
    if (serverList.get(i).ServerType.toString().equalsIgnoreCase("SS") &&
        serverList.get(i).GroupNo.toString().equalsIgnoreCase(groupNo)) {
        try {
            nameofthreads.add("PhoinexHyperlink[" +
                               serverList.get(i).ServerIP + "_" +
                               serverList.get(i).ServerType + "]");
            DeployerThread deployerThread = new DeployerThread(serverList.get(i), action);
            logger.info("---- Start thread execution ---- ");
            deployerThread.start();
            threadsarrforjoin.add(deployerThread);

            Thread.sleep(5000);
        } catch (Exception e) {
            System.out.println(e);
            this.logger.error(e.toString());
          }
        count++;
    }
}

for (int i = 0; i < threadsarrforjoin.size(); i++) {
    try {
        this.threadsarrforjoin.get(i).join();
    } catch (InterruptedException ex) {
        logger.error(ex.getMessage());
        Logger.getLogger(StartStopWebServers.class.getName()).log(Level.SEVERE, null, ex);
      }
}
logger.info(taskName + " Completed");

下面是DeployerThread的代码：

public DeployerThread(ServerConfig serverConfig, String actn, String WEBPROC, String WEBPROC1, String WEBPROCIgnore) {
            logger.debug("Inside DeployerThread constructor");
            logger.debug("serverConfig=" + serverConfig);
            logger.debug("Action=" + actn);
            setServerConfig(serverConfig);
            setTaskaction(actn);
            setWebproc(WEBPROC);
            setWebproc1(WEBPROC1);
            setWebprocignore(WEBPROCIgnore);


        }

        public final ServerConfig getServerConfig() {
            return serverConfig;
        }

        public final void setServerConfig(ServerConfig serverConfig) {
            this.serverConfig = serverConfig;
        }

        public void run() {

            logger.debug("Inside threads run method : Start");
            count++;
            logger.debug("Thread number >>>>" + count + "<<<<");


            Thread.currentThread().setName("[" + serverConfig.ServerIP + "_" + serverConfig.ServerType + "]");
           // threadsarrforjoin.add(Thread.currentThread());
            logger.debug("Name given to this thread=" + "[" + serverConfig.ServerIP + "_" + serverConfig.ServerType + "]");
            org.slf4j.MDC.put("userid", buildPath + "/" + taskName + "/" + taskaction + "_" + Thread.currentThread().getName() + ".log");

            logger.info("Deployment started on " + serverConfig.ServerIP + " for " + serverConfig.ServerType + " at " + dateTimeStamp);
            logger.debug("taskname=" + taskName + "_" + serverConfig.ServerType);

            logger.debug("buildPath=" + buildPath);
            runSSH(serverConfig, action, webproc, webproc1, webprocignore);
            logger.debug("Outside threads run method : End");



        }
    }

下面是线程转储：

“CompilerThread0”后台进程Prio=3 TID=0x002E4310 NID=0x20正在等待条件[0x00000000.0xB3B7EA84]

“AdapterThread”后台进程Prio=3 TID=0x002E34F0 NID=0x1F正在等待条件[0x00000000.0x000000]

“Signal Dispatcher”后台进程Prio=3 TID=0x002E2738 NID=0x1E正在等待条件[0x00000000..0x00000000]

“VM线程”Prio=3 TID=0x002D3C60 NID=0x1B可运行

“GC任务线程#0(ParallelGC)”Prio=3 TID=0x000BA278 NID=0x2可运行

“GC任务线程#1(ParallelGC)”Prio=3 TID=0x000BACC0 NID=0x3可运行

“GC任务线程#5(ParallelGC)”Prio=3 TID=0x000BD5E0 NID=0x7可运行

“GC任务线程#6(ParallelGC)”Prio=3 TID=0x000BE830 NID=0x8可运行

“GC任务线程#7(ParallelGC)”Prio=3 TID=0x000BF278 NID=0x9可运行

“GC任务线程#10(ParallelGC)”Prio=3 TID=0x000C1178 NID=0xC可运行

“GC任务线程#11(ParallelGC)”Prio=3 TID=0x000C1BC0 NID=0xD可运行

“GC任务线程#12(ParallelGC)”Prio=3 TID=0x000C2608 NID=0xE可运行

“GC任务线程#15(ParallelGC)”prio=3 tid=0x000C44E0 nid=0x11可运行

“GC任务线程#16(ParallelGC)”prio=3 tid=0x000C4F30 nid=0x12可运行

“GC任务线程#17(ParallelGC)”prio=3 tid=0x000C5978 nid=0x13可运行

“GC任务线程#19(ParallelGC)”prio=3 tid=0x000C6E08 nid=0x15可运行

“GC任务线程#20(ParallelGC)”prio=3 tid=0x000C7850 nid=0x16可运行

“GC任务线程#21(ParallelGC)”prio=3 tid=0x000C8298 nid=0x17可运行

“VM定期任务线程”Prio=3 TID=0x000B1820 NID=0x23等待条件

Answer 1

看来你用JSCH打开的ssh seesion没有终止；非后台进程线程connect thread仍处于活动状态。如果正如您所说的，您的程序正常运行，请确保断开与jsch会话的连接。

还可以将会话上的daemonthread属性设置为true，以避免ConnectThreadsession.Setdaemonthread(true)导致的挂起。必须在connect()之前调用。