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

 
 
 
Сообщения: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 с таймаутом.
 
Модераторы:Нет
Сейчас эту тему просматривают:Нет