Нечетное поведение с Runnable и ExecutorService

Question

Я получаю очень странное поведение при многопоточности. У меня есть два класса: DipoleTester и Dipole.

DipoleTester пытается создать несколько объектов Dipole, а затем запускать их асинхронно. Проблема в том, что DipoleTester просто запускает все свои объекты Dipole сразу, а не по 2 за раз.

Вот DipoleTester:

public class DipoleTester { 
    public static String DIR = "./save/"; 
    public static void main(String[] args) throws InterruptedException { 
     Dipole trial; 
     ExecutorService service = Executors.newFixedThreadPool(2);  

     for (int r = 10; r < 13; r += 1) { 
      double radius = (double) r/10000.0; 
      for (int matType = 0; matType < 3; matType++) { 
       String name = "Simple_mat"+matType + "_rad" + radius; 
       trial = new DipoleSimple(DIR + "Simple/", name); 
       trial.materialType = matType; 
       trial.RADIUS = radius; 
       service.submit(trial); 

      } 
     } 
     service.shutdown(); 
     service.awaitTermination(100, TimeUnit.HOURS); 
    } 
} 

И вот (соответствующие биты) от диполя

public abstract class Dipole implements Runnable{ 
    ...  
    public void run() { 
     initiate(); 
    } 
    public void initiate() { 
     DateFormat dateFormat = new SimpleDateFormat("MM/dd/yyyy HH:mm:ss"); 
     Date date = new Date(); 
     System.out.println(dateFormat.format(date) + ": Starting: " + NAME); 
     model = ModelUtil.create(NAME); 
     model.modelNode().create("mod1"); 
     makeParams(); 
     makeVariables(); 
     try { 
      Thread.sleep(5000); 
     } catch (InterruptedException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
    } 
    ... 
} 

Сейчас проблема заключается в том, что все потоки выполняются сразу, даже с Thread.sleep (5000)! Я понятия не имею, что происходит. Вот вывод на консоль:

05/08/2013 19:17:31: Starting: Simple_mat0_rad0.001 
05/08/2013 19:17:31: Starting: Simple_mat1_rad0.001 
05/08/2013 19:17:31: Starting: Simple_mat2_rad0.001 
05/08/2013 19:17:31: Starting: Simple_mat0_rad0.0011 
05/08/2013 19:17:31: Starting: Simple_mat1_rad0.0011 
05/08/2013 19:17:31: Starting: Simple_mat2_rad0.0011 
05/08/2013 19:17:31: Starting: Simple_mat0_rad0.0012 
05/08/2013 19:17:31: Starting: Simple_mat1_rad0.0012 
05/08/2013 19:17:31: Starting: Simple_mat2_rad0.0012 

Answer 1

Runnable Ваша задача бросать исключение, прежде чем он дойдет до Thread.sleep() вызова. Это позволяет начать выполнение следующей задачи. Все задачи не работают так быстро, что все они работают одновременно.

Сделайте ставку Thread.sleep() первым, что вы делаете в своем методе run(), и вы увидите, что за один раз запускаются только два потока.

Чтобы обнаружить такие сбои, вам необходимо указать examine экземпляр Future, который возникает в результате каждого звонка до submit(). Есть other methods for submitting a list of tasks оптом и ждут их завершения, что может быть лучше подходит для вашего приложения.