Rename Worker to WorkQueue (ParallelScheduler) (#5232)

Rename Worker to WorkQueue which is ussed from ParallelScheduler.

Signed-off-by: Hanjoung Lee <hanjoung.lee@samsung.com>

diff --git a/runtimes/neurun/core/src/exec/ParallelScheduler.cc b/runtimes/neurun/core/src/exec/ParallelScheduler.cc
index 9424a10..a45079e 100644 (file)
--- a/runtimes/neurun/core/src/exec/ParallelScheduler.cc
+++ b/runtimes/neurun/core/src/exec/ParallelScheduler.cc
@@ -10,7 +10,7 @@ namespace neurun
 namespace exec
 {
 
-Worker::~Worker()
+WorkQueue::~WorkQueue()
 {
   {
     std::unique_lock<std::mutex> lock(_mu);
@@ -19,7 +19,7 @@ Worker::~Worker()
   _cv.notify_all();
 }
 
-void Worker::operator()()
+void WorkQueue::operator()()
 {
   while (true)
   {
@@ -54,7 +54,7 @@ void Worker::operator()()
   }
 }
 
-void Worker::enqueue(std::unique_ptr<IFunction> &&fn)
+void WorkQueue::enqueue(std::unique_ptr<IFunction> &&fn)
 {
   {
     std::unique_lock<std::mutex> lock{_mu};
@@ -63,7 +63,7 @@ void Worker::enqueue(std::unique_ptr<IFunction> &&fn)
   _cv.notify_one();
 }
 
-void Worker::terminate()
+void WorkQueue::terminate()
 {
   {
     std::unique_lock<std::mutex> lock{_mu};
@@ -72,7 +72,7 @@ void Worker::terminate()
   _cv.notify_all();
 }
 
-void Worker::finish()
+void WorkQueue::finish()
 {
   {
     std::unique_lock<std::mutex> lock{_mu};
@@ -81,7 +81,7 @@ void Worker::finish()
   _cv.notify_all();
 }
 
-uint32_t Worker::numJobsInQueue()
+uint32_t WorkQueue::numJobsInQueue()
 {
   std::unique_lock<std::mutex> lock{_mu};
   return _functions.size();

diff --git a/runtimes/neurun/core/src/exec/ParallelScheduler.h b/runtimes/neurun/core/src/exec/ParallelScheduler.h
index f4e7865..9660478 100644 (file)
--- a/runtimes/neurun/core/src/exec/ParallelScheduler.h
+++ b/runtimes/neurun/core/src/exec/ParallelScheduler.h
@@ -35,7 +35,7 @@ namespace exec
 {
 
 // TODO Extract this class to a separate file
-class Worker
+class WorkQueue
 {
 public:
   enum class State
@@ -47,13 +47,13 @@ public:
 
 public:
   /**
-   * @brief Create Worker object
+   * @brief Create WorkQueue object
    */
-  Worker() = default;
+  WorkQueue() = default;
   /**
-   * @brief Destroy Worker object
+   * @brief Destroy WorkQueue object
    */
-  ~Worker();
+  ~WorkQueue();
   /**
    * @brief Thread entry function
    */
@@ -73,7 +73,7 @@ public:
    */
   void finish();
   /**
-   * @brief Check if it has pending jobs. Even if this returns fals, Worker threads may be still
+   * @brief Check if it has pending jobs. Even if this returns fals, WorkQueue threads may be still
    * running
    *
    * @return true if the job queue not empty otherwise false
@@ -123,7 +123,7 @@ private:
   void join();
 
 private:
-  Worker _worker;
+  WorkQueue _worker;
   std::vector<std::thread> _threads;
 };