привет.
как корректно завершить работу потока?
допустим, в потоке выполняется операция.. обработка файла в 10Гб. Как мне правильно отменить/завершить операцию?
Потоки сделаны на boost::thread
варианты:
1. Можно постоянно проверять объект синхронизации на доступность.
2. Можно натыкать boost::this_thread::interrupt_point() и вызывать последовательность

boost::thread::interrupt();
boost::thread::join();

3. некий флаг завершения, который нужно постоянно проверять в потоке.

Но все эти решения неуниверстальны и не дают возможности остановить операцию сразу же по требованию (т.е. работает, пока флаг не будет проверен).
Самый корректный вариант натыкать вызовов boost::this_thread::interrupt_point() и ловить исключение?

Здравствуйте, Аноним, Вы писали:

А>привет.
А>как корректно завершить работу потока?
А>допустим, в потоке выполняется операция.. обработка файла в 10Гб. Как мне правильно отменить/завершить операцию?
А>Потоки сделаны на boost::thread
А>варианты:
А>1. Можно постоянно проверять объект синхронизации на доступность.
А>2. Можно натыкать boost::this_thread::interrupt_point() и вызывать последовательность
А>

А>boost::thread::interrupt();
А>boost::thread::join();
А>

А>3. некий флаг завершения, который нужно постоянно проверять в потоке.

А>Но все эти решения неуниверстальны и не дают возможности остановить операцию сразу же по требованию (т.е. работает, пока флаг не будет проверен).
А>Самый корректный вариант натыкать вызовов boost::this_thread::interrupt_point() и ловить исключение?

Есть два основных способа прибить поток:
1. Ввести флаг, который будет проверяться процедурой потока. В случае взведённого флага — завершение. Если не ошибаюсь, interruot_point() + interrupt() как раз этот механизм и реализуют, через выброс исключения. Плюсы: все объекты могут быть корректно уничтожены. Минусы: требуется работа ручками.
2. Грязный хак с TerminateThread сотоварищи. Плюсы: прибивает поток мгновенно. Минусы: оставляет кучу мусора и захваченных висящих ресурсов.
Вариант №2 использовать крайне не рекомендуется:

If the target thread owns a critical section, the critical section will not be released.
If the target thread is allocating memory from the heap, the heap lock will not be released.
If the target thread is executing certain kernel32 calls when it is terminated, the kernel32 state for the thread's process could be inconsistent.
If the target thread is manipulating the global state of a shared DLL, the state of the DLL could be destroyed, affecting other users of the DLL.

Голосую за:

А>3. некий флаг завершения, который нужно постоянно проверять в потоке.

On 14.04.2011 15:34, Аноним 626 wrote:
> привет.
> как корректно завершить работу потока?

Сказать ему "ЗАВЕРШАЙСЯ" и подождать, пока он завершится.

> 3. некий флаг завершения, который нужно постоянно проверять в потоке.
>

Во-во, вот так и надо.

> Но все эти решения неуниверстальны и не дают возможности остановить операцию
> сразу же по требованию (т.е. работает, пока флаг не будет проверен).

Успокойся, это ВООБЩЕ НЕВОЗМОЖНО без утечек памяти, ресурсов, и прочих прелестей.

Здравствуйте, Аноним, Вы писали:

А>привет.
А>как корректно завершить работу потока?
А>допустим, в потоке выполняется операция.. обработка файла в 10Гб. Как мне правильно отменить/завершить операцию?
А>Потоки сделаны на boost::thread
А>варианты:
А>1. Можно постоянно проверять объект синхронизации на доступность.
А>2. Можно натыкать boost::this_thread::interrupt_point() и вызывать последовательность
А>

А>boost::thread::interrupt();
А>boost::thread::join();
А>

А>3. некий флаг завершения, который нужно постоянно проверять в потоке.

Вариант 1 имеет преимущество, что можно ждать чего-то и одновременно привитив для прерывания. Например, полезно при использовании Overlapped IO в Windows, таким образом можно прервать во время операции ввода-вывода.
Вариант 2 имеет преимущество, что ожидание на бустовских примитивах сихнронизации тоже прерывается через boost::thread::interrupt().
Вариант 3 имеет преимущество, что проверить флаг дешевле, чем настоящий примитив синхронизации.

А>Но все эти решения неуниверстальны и не дают возможности остановить операцию сразу же по требованию.
да.

А>Самый корректный вариант натыкать вызовов boost::this_thread::interrupt_point() и ловить исключение?

Все варианты корректны. Ловить исключение boost::thread_interrupted не обязательно для потоков на boost::thread — оно будет словлено само.

Здравствуйте, MasterZiv, Вы писали:

MZ>Успокойся, это ВООБЩЕ НЕВОЗМОЖНО без утечек памяти, ресурсов, и прочих прелестей.

ВООБЩЕ НЕВОЗМОЖНО это типа как бы ещё круче, чем просто невозможно? Есть lockfree, есть ОС, внешние программы. Это всего лишь сложно, но конечно же возможно.

Здравствуйте, Аноним, Вы писали:

А>3. некий флаг завершения, который нужно постоянно проверять в потоке.
А>Самый корректный вариант натыкать вызовов boost::this_thread::interrupt_point() и ловить исключение?

1) Суть отличия (3) от "самого коректного" не уловил.
2) А зачем нужно прибить нить мгновенно? Можно, например, задавить ей приоритет, и выставить флаг "умри, когда сможешь"...
3) Если уж так надо уметь асинхронно убивать какую-то нить, то намного прямее вынести её в отдельный процесс. Риски нагнуть ОС всё равно могут быть, но намного ниже. Процессы таки лучше изолированы друг от друга, чем нити в одном...

Здравствуйте, MasterZiv, Вы писали:

MZ>Успокойся, это ВООБЩЕ НЕВОЗМОЖНО без утечек памяти, ресурсов, и прочих прелестей.

детский сад. это делается асинхронными исключениями, GC или выделением ресурсов из пула