Запуск нескольких ExecutorService Java

Question

Я хочу одновременно запустить два ExecutorService.

Например, в моей основной:

MyClass.firstAsync(); 
MyClass.secondAsync(); 

и

public void firstAsync() { 
ExecutorService service = Executors.newFixedThreadPool(4); 
    service.submit(new Runnable() { 
     public void run() { 
      while (true) { 
       System.out.println("I m running : First Async"); 
     } 
    }); 
} 

затем

public void secondAsync() { 
    ExecutorService service = Executors.newFixedThreadPool(4); 
     service.submit(new Runnable() { 
      public void run() { 
      while (true) { 
       System.out.println("I m running : Second Async"); 
       } 
     }); 
    } 

Проблема: когда называется второй класс, он занимает место первого. Поэтому у меня есть этот выход:

I m running : First Async 

в то время как второй ExecutorService is'nt запущен, но у меня есть этот выход

I m running : Second Async 

, когда вторая запускается.

Я также попытался поставить их на ту же услугу (есть два service.submit (...) на одной и той же ExecutorService), но он не работает на всех

То, что я хочу оба выхода , в то же время".

Благодарим вас, Clément.

Answer 1

Вы не можете рассчитывать контролировать выполнение потоков. Если вы хотите, чтобы имитировать его, давайте познакомимся в ваших петлях:

Thread.sleep(10); 

Это заставляет ток, протекающую тему сна, и дает шанс другим потокам для выполнения.

Но не ожидайте, чтобы организовать выполнение потока.

Answer 2

Ваш код работает должным образом. Я предполагаю, что вы ожидали получить такой результат:

I m running : First Async 
I m running : Second Async 
I m running : First Async 
I m running : Second Async 

Но вместо этого вы получаете:

I m running : First Async 
I m running : First Async 
... 
I m running : First Async 
I m running : Second Async 
I m running : Second Async 
... 
I m running : Second Async 
I m running : First Async 
... 
I m running : First Async 
I m running : Second Async 
... 
I m running : Second Async 

А может быть, вы получаете так много выход из одного потока, что вы не видите выход из другой.

Это происходит потому, что оба потока конкурируют за доступ к одному и тому же выходному потоку (System.out), и каждый раз, когда у него есть доступ, ему удается распечатать несколько строк (может быть, тысячи), прежде чем другой поток получит разрешение по потоку.

Чтобы проверить это, добавьте задержку в своих циклах, чтобы каждый поток успевал печатать только одну строку за раз.

while (true) { 
    System.out.println("I m running : First Async"); 
    Thread.sleep(100); // <---- and surround with try-catch 
} 
while (true) { 
    System.out.println("I m running : Second Async"); 
    Thread.sleep(100); // <---- and surround with try-catch 
} 

Answer 3

(1) Ваш код в порядке (за исключением некоторых незначительных замечаний ниже), проблема в том, что просто фактический код слишком быстро, чтобы заметить параллелизм! Кроме того, println обычно синхронизируется. Если вы замените каждый «run()» на некоторый цикл, который печатает несколько строк, вы заметите параллелизм.

(2) Я бы рассмотрел два исправления, независимо: (a) Вам действительно нужны 2 отдельных пула потоков? Это нормально, если вы это делаете, просто причина не ясна из примера. (B) Я не вижу большого смысла в создании пула потоков в качестве локальной переменной метода, его следует разместить там, где он может быть повторно использован + контролируется + завершается когда-то. Очевидно, вы, возможно, просто упростили код для обсуждения ...

Answer 4

Я хотел бы сделать комментарий, но, видимо, мне нужно 50 репутации на stackoverflow, чтобы прокомментировать (резонирующий, но неудачный.). Поэтому я попытаюсь ответить на этот вопрос.

ExecutorService предназначен для управления объектом, который реализует интерфейс Executor, это означает, что он может содержать в нем threadpool. Пул потоков может использоваться для размещения разнообразных объектов Runnable thread. Они не должны быть одного типа.

Так, например, если у вас был класс Runable с определенной функцией, вы можете запустить это из потока, хранящегося в ExecutorService, потому что потоки являются общими. Если вам требуется идентифицировать конкретные потоки для взаимодействия с ними позже, вы можете иметь определенное поле неизменяемого идентификатора класса с методом getter в каждом типе типа Runnable. Или, если хотите, вы можете сохранить ссылку на объект потока при его создании.

В качестве альтернативы существует возможность поиска текущих потоков/групп потоков и их идентификаторов. Вы можете увидеть этот метод здесь:

http://nadeausoftware.com/articles/2008/04/java_tip_how_list_and_find_threads_and_thread_groups#GettingThreadGroups

Ответ на ваш вопрос в том, что вам не нужно иметь два ExecutorServices. Поскольку вы можете размер пула потоков в статическом или динамическом режиме, и ваш threadpool может содержать объекты хетрогенной нити.

Надеюсь, это поможет. И я надеюсь, что это адекватный ответ.

Answer 5

Вот мой окончательный ответ.

В моем коде firstAsync() появилось исключение NullPointerException, которое НИКОГДА не отображалось на консоли.

Я потратил больше часа на то, чтобы найти парня из моей службы. Это мое плохое. Ваш ответ был хорошим, и мой вопрос был глупым.

Thank's, Clément.