X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fjob.cc;h=04aa227b7a46c749f03c6ae56e6eb43a66645f38;hb=ea6b2dae46caa1da829fbf499e83cd6ae3b3773a;hp=8966a65e700eb84b8f3945eb7d81987d8c88f7b5;hpb=a1546fb6c4e59621d99271b8ca996e96a574f7b3;p=dcpomatic.git diff --git a/src/lib/job.cc b/src/lib/job.cc index 8966a65e7..04aa227b7 100644 --- a/src/lib/job.cc +++ b/src/lib/job.cc @@ -51,7 +51,6 @@ using namespace dcpomatic; /** @param film Associated film, or 0 */ Job::Job (shared_ptr film) : _film (film) - , _thread (0) , _state (NEW) , _start_time (0) , _sub_start_time (0) @@ -69,20 +68,16 @@ Job::~Job () void Job::stop_thread () { - if (_thread) { - _thread->interrupt (); - /* We can't use DCPOMATIC_ASSERT here as it may throw an exception */ - if (_thread->joinable ()) { - try { - _thread->join (); - } catch (...) { - /* Too late to do anything about this */ - } - } + if (!_thread.joinable()) { + return; } - delete _thread; - _thread = 0; + _thread.interrupt (); + try { + _thread.join (); + } catch (...) { + /* Too late to do anything about this */ + } } /** Start the job in a separate thread, returning immediately */ @@ -92,9 +87,9 @@ Job::start () set_state (RUNNING); _start_time = time (0); _sub_start_time = time (0); - _thread = new boost::thread (boost::bind (&Job::run_wrapper, this)); + _thread = boost::thread (boost::bind(&Job::run_wrapper, this)); #ifdef DCPOMATIC_LINUX - pthread_setname_np (_thread->native_handle(), "job-wrapper"); + pthread_setname_np (_thread.native_handle(), "job-wrapper"); #endif } @@ -515,7 +510,7 @@ Job::remaining_time () const void Job::cancel () { - if (!_thread) { + if (!_thread.joinable()) { return; } @@ -523,11 +518,8 @@ Job::cancel () resume (); } - _thread->interrupt (); - DCPOMATIC_ASSERT (_thread->joinable ()); - _thread->join (); - delete _thread; - _thread = 0; + _thread.interrupt (); + _thread.join (); } /** @return true if the job was paused, false if it was not running */