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() + ")"); 


    } 
}