1

我在我的程序中创建了一些线程。这里我使用了 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");



        }
    }

下面是线程转储：

全线程转储 Java HotSpot(TM) Server VM（1.5.0_30-b03 混合模式）：

“DestroyJavaVM”prio=3 tid=0x00037840 nid=0x1 等待条件 [0x00000000..0xffbfe3d0]

“连接线程 172.24.85.166 会话”prio=3 tid=0x006bcdb0 nid=0x25 runnable [0xb29af000..0xb29afbf0] 在 java.net.SocketInputStream.socketRead0(Native Method) 在 java.net.SocketInputStream.read(SocketInputStream.java:129 ）在 com.jcraft.jsch.IO.getByte(IO.java:82) 在 com.jcraft.jsch.Session.read(Session.java:860) 在 com.jcraft.jsch.Session.run(Session.java:第1330章）

“内存不足检测器”守护进程 prio=3 tid=0x002e6fc8 nid=0x22 可运行 [0x00000000..0x00000000]

“CompilerThread1”守护进程prio=3 tid=0x002e5130 nid=0x21 等待条件[0x00000000..0xb3aee9bc]

“CompilerThread0”守护进程prio=3 tid=0x002e4310 nid=0x20 等待条件[0x00000000..0xb3b7ea84]

“AdapterThread”守护进程prio=3 tid=0x002e34f0 nid=0x1f 等待条件[0x00000000..0x00000000]

“信号调度程序”守护进程 prio=3 tid=0x002e2738 nid=0x1e 等待条件 [0x00000000..0x00000000]

“终结器”守护进程 prio=3 tid=0x002d8d68 nid=0x1d in Object.wait() [0xb3d2f000..0xb3d2fbf0] at java.lang.Object.wait(Native Method) - 等待 <0xe3001418> (a java.lang.ref .ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:120) - 在 java.lang.ref.ReferenceQueue.remove( ReferenceQueue.java:136) 在 java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:159)

“参考处理程序”守护进程 prio=3 tid=0x002d7648 nid=0x1c in Object.wait() [0xb3dbf000..0xb3dbfc70] at java.lang.Object.wait(Native Method) - 等待 <0xe3001218> (a java.lang. ref.Reference$Lock) at java.lang.Object.wait(Object.java:474) at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:116) - 锁定 <0xe3001218>（一个 java.lang .ref.Reference$Lock)

“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 任务线程#2 (ParallelGC)”prio=3 tid=0x000bb708 nid=0x4 可运行

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

“GC 任务线程#4 (ParallelGC)”prio=3 tid=0x000bcb98 nid=0x6 可运行

“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 任务线程#8 (ParallelGC)”prio=3 tid=0x000bfcc0 nid=0xa 可运行

“GC 任务线程#9 (ParallelGC)”prio=3 tid=0x000c0730 nid=0xb 可运行

“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 任务线程#13 (ParallelGC)”prio=3 tid=0x000c3050 nid=0xf 可运行

“GC 任务线程#14 (ParallelGC)”prio=3 tid=0x000c3a98 nid=0x10 可运行

“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 任务线程#18 (ParallelGC)”prio=3 tid=0x000c63c0 nid=0x14 可运行

“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 可运行

“GC 任务线程#22 (ParallelGC)”prio=3 tid=0x000c8ce0 nid=0x18 可运行

“GC 任务线程#23 (ParallelGC)”prio=3 tid=0x000c9728 nid=0x19 可运行

“GC 任务线程#24 (ParallelGC)”prio=3 tid=0x000ca170 nid=0x1a 可运行

“VM 定期任务线程”prio=3 tid=0x000b1820 nid=0x23 等待条件

4

1 回答 1

2

似乎您使用 JSCH 打开的 ssh 访问没有终止；非守护线程Connect thread仍然存在。如果如您所说，您的程序运行正常，请务必断开与 jsch 会话的连接。

您还可以将会DaemonThread话上的属性设置为 true 以避免由 ConnectThread 引起的挂起session.setDaemonThread(true)。必须在之前调用connect()。

于 2013-05-24T07:40:55.400 回答