Сколько потоков работает в моей программе java?

Question

Я бег простой программы и здесь необходимо войти

Total Thread : 6 // using Thread.activeCount() 
pool-1-thread-143 

Вот класс

public class Test implements Runnable{ 

    String    ul; 
    ExecutorService  threadPool; 
    public Test(String s, ExecutorService executor) 
    { 
     this.ul = s; 
     threadPool = executor; 
    } 

    public void run() { 
     try { 
      Fun(ul); 
     } catch (IOException ex) { 
      ex.printStackTrace(); 
     } 
    } 

    private void Fun(String ss) throws IOException 
    { 

    // .... 
     System.out.println("Total Thread : "+Thread.activeCount()); 
     Iterator iterator = links.iterator(); 
     while(iterator.hasNext()) 
     { 
      Element ele = iterator.next(); 
      String s = ele.getprop("...."); 
      if(!Model.condition(s)) 
      { 
       System.out.println(Thread.currentThread().getName()); 
       threadPool.execute(new Test(s, threadPool)); 
      } 
     }   
    } 
} 

Здесь Main.java

ExecutorService executor = Executors.newFixedThreadPool(5);   
    executor.execute(new Test("this is something", executor));   
    while (!executor.isTerminated()) { }   

Так сколько фактический потока выполняется с помощью моей программы ? Я применил executor.execute() правильно в этой программе?

Answer 1

Один поток для основной программы и пять потоков в бассейне в общей сложности 6, как вы видите. И это отлично подходит для Threadpool, хотя кажется немного запутанным, что Test выполняет новый Test?!

Приветствия,

Answer 2

Executors вызов создает размер пула потоков из 5. неподвижную приложение запускается на main нить ... Таким образом, 5 + 1 = 6

Answer 3

Внедрение кода немного неуклюжим. Эта часть выглядит немного уродливой threadPool.execute(new Test(s, threadPool));, поскольку вы передаете ссылку переменной как параметр, который сам вызывает вызов метода.

Я предпочел бы сохранить исполнитель пула потоков вне класса Test и передать ему несколько экземпляров тестового класса.

Подсчитайте, как объяснено в ответах выше, это 5 + 1 основная тема.

Вот как я это сделаю. Основной метод может быть дополнительно улучшен путем добавления большей модульности, но цель заключается в том, что ThreadPool должен существовать вне реализации Runnable.

public class Test implements Runnable{ 

    String    ul;  
    public Test(String s) 
    { 
     this.ul = s;   
    } 

    public void run() { 
     try { 
      Fun(ul); 
     } catch (IOException ex) { 
      ex.printStackTrace(); 
     } 
    } 

    private void Fun(String ss) throws IOException 
    { 

    // .... 
     System.out.println("Total Thread : "+Thread.activeCount()); 

     System.out.println(Thread.currentThread().getName()); 

     }   
    } 
} 

public class MyRunnerClass { 

    public static void main(String args[]){ 
    ExecutorService executor = Executors.newFixedThreadPool(5); 
    String s = "this is something"; 

     Iterator iterator = links.iterator(); 
     while(iterator.hasNext()) 
     { 
      Element ele = iterator.next(); 
      String s = ele.getprop("...."); 
      if(!Model.condition(s)) 
      {    
       executor.execute(new Test(s, threadPool)); 
      } 
     } 

    } 
}