Swap a few APIs to reduce sign and implicit truncations required to work with it

[folly.git] / folly / gen / Parallel-inl.h

diff --git a/folly/gen/Parallel-inl.h b/folly/gen/Parallel-inl.h
index 18c7c4342d0a32f35c7857ca34932e2207f2fbc4..1e225c20512dfeedfb64b4463154c109866a668c 100644 (file)
--- a/folly/gen/Parallel-inl.h
+++ b/folly/gen/Parallel-inl.h
@@ -49,7 +49,7 @@ class ClosableMPMCQueue {
   void openConsumer() { ++consumers_; }
 
   void closeInputProducer() {
-    int64_t producers = producers_--;
+    size_t producers = producers_--;
     CHECK(producers);
     if (producers == 1) { // last producer
       wakeConsumer_.notifyAll();
@@ -57,7 +57,7 @@ class ClosableMPMCQueue {
   }
 
   void closeOutputConsumer() {
-    int64_t consumers = consumers_--;
+    size_t consumers = consumers_--;
     CHECK(consumers);
     if (consumers == 1) { // last consumer
       wakeProducer_.notifyAll();