worker.hpp

Go to the documentation of this file.

#pragma once
 
#include "declarations.hpp"
#include "tsq.hpp"
#include "notifier.hpp"
 
namespace tf {
 
// ----------------------------------------------------------------------------
// Class Definition: Worker
// ----------------------------------------------------------------------------
 
class Worker {
 
  friend class Executor;
  friend class WorkerView;
 
  private:
 
    size_t _id;
    size_t _vtm;
    Executor* _executor;
    Notifier::Waiter* _waiter;
    std::default_random_engine _rdgen { std::random_device{}() };
    TaskQueue<Node*> _wsq;
};
 
// ----------------------------------------------------------------------------
// Class Definition: PerThreadWorker
// ----------------------------------------------------------------------------
 
//struct PerThreadWorker {
//
//  Worker* worker;
//
//  PerThreadWorker() : worker {nullptr} {}
//
//  PerThreadWorker(const PerThreadWorker&) = delete;
//  PerThreadWorker(PerThreadWorker&&) = delete;
//
//  PerThreadWorker& operator = (const PerThreadWorker&) = delete;
//  PerThreadWorker& operator = (PerThreadWorker&&) = delete;
//};
 
//inline PerThreadWorker& this_worker() {
//  thread_local PerThreadWorker worker;
//  return worker;
//}
 
// ----------------------------------------------------------------------------
// Class Definition: WorkerView
// ----------------------------------------------------------------------------
 
class WorkerView {
 
  friend class Executor;
 
  public:
 
    size_t id() const;
 
    size_t queue_size() const;
 
    size_t queue_capacity() const;
 
  private:
 
    WorkerView(const Worker&);
    WorkerView(const WorkerView&) = default;
 
    const Worker& _worker;
 
};
 
// Constructor
inline WorkerView::WorkerView(const Worker& w) : _worker{w} {
}
 
// function: id
inline size_t WorkerView::id() const {
  return _worker._id;
}
 
// Function: queue_size
inline size_t WorkerView::queue_size() const {
  return _worker._wsq.size();
}
 
// Function: queue_capacity
inline size_t WorkerView::queue_capacity() const {
  return static_cast<size_t>(_worker._wsq.capacity());
}
 
 
}  // end of namespact tf -----------------------------------------------------