Блог

У меня есть программа, которая предназначена для многопоточности. У меня есть ProcessRunnable класс, который обрабатывает данные с большим количеством требуемых операций ввода-вывода. ProcessRunnable Все классы выполняются в отдельных потоках, но создаются с помощью общих экземпляров клиентских / util-классов.

Пример:

 Client client = new Client();
Util util = new Util();

List<Runnable> runnables = new ArrayList<>();

for (int i; i < THREAD_COUNT; i  ) {
    runnables.add(ProcessRunnable
                       .builder()
                       .client(client)
                       .util(util)
                       .build());
}

runnables.forEach(runnable -> new Thread(runnable).start());
  

Мне любопытно, блокирует ли повторное использование одних и тех же экземпляров классов в runnables поведение и, по сути, приводит к тому, что моя программа становится однопоточной?

Здесь:

 runnable -> new Thread(runnable).start()
  

Ключевой момент, который фактически делает ваш код многопоточным, заключается в том, что вы вызываете метод start() ваших объектов потока. Если бы вы просто вызвали метод run класса thread, то в конечном итоге «заключающий» поток выполнял бы всю работу.

Наконец, пожалуйста, обратите внимание, что прямое использование «голых» потоков не идеально. Об этом можно узнать, но Java предлагает важные абстракции, такие как ExecutorService, которые следует использовать вместо этого по разным причинам.

Основная причина избегать необработанных потоков: вы должны контролировать все тонкие детали вручную. Сколько потоков следует использовать? Как насчет объединения потоков и совместного использования (создание потока сопряжено с большими накладными расходами, поэтому в реальном мире вы избегаете создания потоков для отдельных задач, чтобы затем отбросить их, как это делает ваш код). Помимо этого: обычно вы хотите решить бизнес-проблему. Вы хотите использовать несколько потоков, чтобы предотвратить ситуации с бутылочным горлышком. Пример: вы хотите сделать несколько запросов по сети параллельно для извлечения и обработки данных. Тогда вас действительно волнует только конечный результат, а не тонкости потоковой обработки низкого уровня! Тогда вы могли бы, например, использовать объекты Future или CompleteableFuture.

Просто воспользуйтесь поисковой системой и изучите эти термины, вы найдете множество материалов.