X-Git-Url: http://plrg.eecs.uci.edu/git/?p=folly.git;a=blobdiff_plain;f=folly%2FProducerConsumerQueue.h;fp=folly%2FProducerConsumerQueue.h;h=92eb0d4a96f74b02561e5e501044aa1e1981946a;hp=ff1a4fe13b3dbe35903c4adf5dee3ac0a85f10d4;hb=7fdf8141e4d3737ac2c45c16830a8dbaac19b445;hpb=bc374dcbb0e552826e4bcbed1d8cbd479ce062c0 diff --git a/folly/ProducerConsumerQueue.h b/folly/ProducerConsumerQueue.h index ff1a4fe1..92eb0d4a 100644 --- a/folly/ProducerConsumerQueue.h +++ b/folly/ProducerConsumerQueue.h @@ -61,8 +61,8 @@ struct ProducerConsumerQueue : private boost::noncopyable { // (No real synchronization needed at destructor time: only one // thread can be doing this.) if (!boost::has_trivial_destructor::value) { - int read = readIndex_; - int end = writeIndex_; + size_t read = readIndex_; + size_t end = writeIndex_; while (read != end) { records_[read].~T(); if (++read == size_) { @@ -168,8 +168,8 @@ private: const uint32_t size_; T* const records_; - std::atomic readIndex_; - std::atomic writeIndex_; + std::atomic readIndex_; + std::atomic writeIndex_; }; }