VPF::Не останавливаются потоки - Форум программистов

Kreatifchk

Дата 7.10.2020, 18:10 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 4
Регистрация: 11.7.2015

Репутация: нет
Всего: нет

Имеется такой код:

Код


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();
}

Tasks - это ArrayBlockingQueue<Runnable> .

Переменная unlock - volatile, и когда я меняю ее на true потоки должны остановиться, но почему-то останавливаются только несколько потоков, а остальные продолжают висеть (проверено через дебагер), а в них ничего не исполняется.
Выглядит это примерно так:
user posted image

Но если вставить 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();
}

То тогда отлично завершаются все потоки. Такое, же происходит если в собственно задачу в tasks вставить System.out.println .

Kreatifchk

Дата 7.10.2020, 19:55 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 4
Регистрация: 11.7.2015

Репутация: нет
Всего: нет

Причина найдена, метод take у блокирующей очереди в определенный момент блокировал поток, а поскольку задач больше не поступало, блокировка не снималась. Решением стало заменить метод take на pool с таймаутом.

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »