X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/b86bce0900f88c530f23dd602a8f2ef9ce008f8a..f0dcb6b97d6d40f67698d1f71ac26970f1776f82:/rpc/thr_pool.cc?ds=sidebyside

diff --git a/rpc/thr_pool.cc b/rpc/thr_pool.cc
index 73f94f4..fc7be3d 100644
--- a/rpc/thr_pool.cc
+++ b/rpc/thr_pool.cc
@@ -1,42 +1,33 @@
 #include "thr_pool.h"
-#include <stdlib.h>
-#include <errno.h>
-#include "lang/verify.h"
 
 // if blocking, then addJob() blocks when queue is full
 // otherwise, addJob() simply returns false when queue is full
-ThrPool::ThrPool(int sz, bool blocking)
-: nthreads_(sz),blockadd_(blocking),jobq_(100*sz) 
-{
-	for (int i=0; i<nthreads_; i++)
-        th_.emplace_back(&ThrPool::do_worker, this);
+thread_pool::thread_pool(size_t sz, bool blocking)
+: nthreads_(sz),blockadd_(blocking),jobq_(100*sz) {
+    for (size_t i=0; i<nthreads_; i++)
+        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
-ThrPool::~ThrPool()
-{
-	for (int i=0; i<nthreads_; i++)
-		jobq_.enq(job_t());
+thread_pool::~thread_pool() {
+    for (size_t i=0; i<nthreads_; i++)
+        jobq_.enq(job_t());
 
-	for (int i=0; i<nthreads_; i++)
+    for (size_t i=0; i<nthreads_; i++)
         th_[i].join();
 }
 
-bool 
-ThrPool::addJob(const job_t &j)
-{
-	return jobq_.enq(j,blockadd_);
+bool thread_pool::addJob(const job_t & j) {
+    return jobq_.enq(j,blockadd_);
 }
 
-void
-ThrPool::do_worker()
-{
+void thread_pool::do_worker() {
     job_t j;
-	while (1) {
+    while (1) {
         jobq_.deq(&j);
-		if (!j)
-			break;
-		j();
-	}
+        if (!j)
+            break;
+        j();
+    }
 }