java：线程完全不能完成run（）方法吗？

Question

我有一个程序，它探索文件系统，从一个给定的root.the程序递归地探索从根点的所有目录，并在tiff文件上执行一个过程。确实它合并了每个两个tiff文件。我使用ExecutorService和ThreadPoolExecutor来处理合并函数。

 ExecutorService exec = Executors.newFixedThreadPool(threadsNumber); 
    inputDirectoryProcess(inputDir); 
    exec.shutdown(); 
    try { 
     exec.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS); 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 

成为每一个合并功能我用以下：

exec.submit(new MultipageTask(a, Integer.toString(intDetector(directoryFiles.get(i + 1).getName())/2), out)); 

以下是MultipageTask类：

 public void run() { 

     Thread thread = Thread.currentThread(); 
     System.out.println("start by " + thread.getName() + " (" + thread.getId() + ")"); 

     Integer[] resoulutions = null; 

     try { 

      BufferedImage image[] = new BufferedImage[tifImages.length]; 
      for (int i = 0; i < tifImages.length; i++) { 
       resoulutions = getsize(tifImages[i].getPath()); 
       SeekableStream ss = null; 
       ss = new FileSeekableStream(tifImages[i]); 
       ImageDecoder decoder = ImageCodec.createImageDecoder("tiff", ss, null); 

       PlanarImage op = null; 
       op = new NullOpImage(decoder.decodeAsRenderedImage(0), 
         null, OpImage.OP_IO_BOUND, null); 
       image[i] = op.getAsBufferedImage(); 
      } 

      TIFFField[] fields = new TIFFField[3]; 
      // ResolutionUnit 
      TIFFField fieldResUnit = new TIFFField(296, TIFFField.TIFF_SHORT, 1, 
        (Object) new char[] { 2 }); 
      fields[0] = fieldResUnit; 

      // XResolution 
      TIFFField fieldXRes = new TIFFField(282, TIFFField.TIFF_RATIONAL, 1, 
        (Object) new long[][] { { resoulutions[0], 1 } }); 
      fields[1] = fieldXRes; 

      // YResolution 
      TIFFField fieldYRes = new TIFFField(283, TIFFField.TIFF_RATIONAL, 1, 
        (Object) new long[][] { { resoulutions[1], 1 } }); 
      fields[2] = fieldYRes; 

      TIFFEncodeParam params = new TIFFEncodeParam(); 
      params.setCompression(TIFFEncodeParam.COMPRESSION_GROUP4); 
      params.setExtraFields(fields); 
      OutputStream out = new FileOutputStream(outDir + "\\" + image_name + ".tif"); 
      ImageEncoder encoder = ImageCodec.createImageEncoder("tiff", out, params); 
      Vector vector = new Vector(); 
      for (int i = 1; i < tifImages.length; i++) { 
       vector.add(image[i]); 
      } 
      params.setExtraImages(vector.iterator()); 
      encoder.encode(image[0]); 
      out.close(); 
      System.out.println("end by " + thread.getName() + " (" + thread.getId() + ")"); 

     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
     increasetCount(); 
    } 
} 

public synchronized void increasetCount() { 
    convertCount = convertCount + 2; 
    updateBar(convertCount); 
} 

节目结束后，我注意到，一些文件没有处理。所以我登录进入和退出线程如上所示。在控制台中，我看到以下几行：

start by pool-2-thread-4 (30) 
end by pool-2-thread-2 (28) 
start by pool-2-thread-2 (28) 
start by pool-2-thread-4 (30) 
start by pool-2-thread-2 (28) 
start by pool-2-thread-1 (27) 
start by pool-2-thread-1 (27) 
start by pool-2-thread-4 (30) 
end by pool-2-thread-1 (27) 
end by pool-2-thread-2 (28) 
start by pool-2-thread-1 (27) 
start by pool-2-thread-2 (28) 

正如你看到一些像28启动的线程，但没有完成。这导致失去了一些合并过程和程序无法处理所有的tiff文件。

注：我应该提到，当我增加threadsNumber时，缺少的增加！

我该如何解决？我想确保每个线程完成运行过程。

感谢和抱歉，因为糟糕的英语。

Answer 1

，如果你没有共享资源和它不是一个死锁/活锁，尝试用

public class MultipageTask implements Runnable { 
    private File[] tifImages; 
    private String image_name; 
    private String outDir; 

    public MultipageTask(File[] tifImages, String image_name, String outDir) { 
     this.tifImages = tifImages; 
     this.image_name = image_name; 
     this.outDir = outDir; 
    } 

    @Override 
    public void run() { 

     Thread thread = Thread.currentThread(); 
     System.out.println("start by " + thread.getName() + " (" + thread.getId() + ")"); 

      try{ 
       // doing merge process 
      }catch(Exception e){ 
       e.printStackTrace(); 
      } 
      System.out.println("end by " + thread.getName() + " (" + thread.getId() + ")"); 


    } 
}