Cosmetic improvements.

[invirt/third/libt4.git] / rpc / thr_pool.cc

diff --git a/rpc/thr_pool.cc b/rpc/thr_pool.cc
index 64b3263..fc7be3d 100644 (file)
--- a/rpc/thr_pool.cc
+++ b/rpc/thr_pool.cc
@@ -2,15 +2,15 @@
 
 // if blocking, then addJob() blocks when queue is full
 // otherwise, addJob() simply returns false when queue is full
 
 // if blocking, then addJob() blocks when queue is full
 // otherwise, addJob() simply returns false when queue is full

-ThrPool::ThrPool(size_t sz, bool blocking)
+thread_pool::thread_pool(size_t sz, bool blocking)

 : nthreads_(sz),blockadd_(blocking),jobq_(100*sz) {
     for (size_t i=0; i<nthreads_; i++)
 : nthreads_(sz),blockadd_(blocking),jobq_(100*sz) {
     for (size_t i=0; i<nthreads_; i++)

-        th_.emplace_back(&ThrPool::do_worker, this);
+        th_.emplace_back(&thread_pool::do_worker, this);

 }
 
 // IMPORTANT: this function can be called only when no external thread 
 // will ever use this thread pool again or is currently blocking on it
 }
 
 // IMPORTANT: this function can be called only when no external thread 
 // will ever use this thread pool again or is currently blocking on it

-ThrPool::~ThrPool() {
+thread_pool::~thread_pool() {

     for (size_t i=0; i<nthreads_; i++)
         jobq_.enq(job_t());
 
     for (size_t i=0; i<nthreads_; i++)
         jobq_.enq(job_t());
 

@@ -18,11 +18,11 @@ ThrPool::~ThrPool() {
         th_[i].join();
 }
 
         th_[i].join();
 }
 

-bool ThrPool::addJob(const job_t &j) {
+bool thread_pool::addJob(const job_t & j) {

     return jobq_.enq(j,blockadd_);
 }
 
     return jobq_.enq(j,blockadd_);
 }
 

-void ThrPool::do_worker() {
+void thread_pool::do_worker() {

     job_t j;
     while (1) {
         jobq_.deq(&j);
     job_t j;
     while (1) {
         jobq_.deq(&j);