Не завершаются потоки

 
 
 
Сообщения:9
Имеется такой код:

for (int i = 0; i < thread; i++) {
    new Thread(() -> {
		while (!unlock) {
			if (tasks.size() > 0) {
				try {
					tasks.take().run();
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		}
	}).start();
}


Переменная unlock - volatile, и когда я меняю ее на true потоки должны остановиться, но почему-то останавливаются только несколько потоков, а остальные продолжают висеть (проверено через дебагер), но если вставить System.out.println , в конец цикла, вот так

for (int i = 0; i < thread; i++) {
    new Thread(() -> {
		while (!unlock) {
			if (tasks.size() > 0) {
				try {
					tasks.take().run();
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
			System.out.println(unlock);
		}
	}).start();
}




То всё начинает работать как надо.В чем причина?
 
 
Сообщения:9
Причина найдена, метод take у блокирующей очереди в определенный момент блокировал поток, а поскольку задач больше не поступало, блокировка не снималась. Решением стало заменить метод take на pool с таймаутом.
 
Модераторы:Нет
Сейчас эту тему просматривают:Нет