diff options
Diffstat (limited to 'host/lib/utils')
| -rw-r--r-- | host/lib/utils/tasks.cpp | 14 | 
1 files changed, 8 insertions, 6 deletions
diff --git a/host/lib/utils/tasks.cpp b/host/lib/utils/tasks.cpp index 993b484ea..1f735de06 100644 --- a/host/lib/utils/tasks.cpp +++ b/host/lib/utils/tasks.cpp @@ -27,10 +27,11 @@ using namespace uhd;  class task_impl : public task{  public: -    task_impl(const task_fcn_type &task_fcn){ -        boost::barrier spawn_barrier(2); -        _thread_group.create_thread(boost::bind(&task_impl::task_loop, this, task_fcn, boost::ref(spawn_barrier))); -        spawn_barrier.wait(); +    task_impl(const task_fcn_type &task_fcn): +        _spawn_barrier(2) +    { +        _thread_group.create_thread(boost::bind(&task_impl::task_loop, this, task_fcn)); +        _spawn_barrier.wait();      }      ~task_impl(void){ @@ -41,9 +42,9 @@ public:  private: -    void task_loop(const task_fcn_type &task_fcn, boost::barrier &spawn_barrier){ +    void task_loop(const task_fcn_type &task_fcn){          _running = true; -        spawn_barrier.wait(); +        _spawn_barrier.wait();          try{              while (_running){ @@ -72,6 +73,7 @@ private:      }      boost::thread_group _thread_group; +    boost::barrier _spawn_barrier;      bool _running;  };  | 
