/*
- * Copyright 2016 Facebook, Inc.
+ * Copyright 2017 Facebook, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
#include <atomic>
#include <cassert>
#include <cstdlib>
+#include <memory>
#include <stdexcept>
#include <type_traits>
#include <utility>
+#include <folly/concurrency/CacheLocality.h>
+
namespace folly {
/*
// (No real synchronization needed at destructor time: only one
// thread can be doing this.)
if (!std::is_trivially_destructible<T>::value) {
- size_t read = readIndex_;
- size_t end = writeIndex_;
- while (read != end) {
- records_[read].~T();
- if (++read == size_) {
- read = 0;
+ size_t readIndex = readIndex_;
+ size_t endIndex = writeIndex_;
+ while (readIndex != endIndex) {
+ records_[readIndex].~T();
+ if (++readIndex == size_) {
+ readIndex = 0;
}
}
}
}
private:
- const uint32_t size_;
- T* const records_;
+ char pad0_[CacheLocality::kFalseSharingRange];
+ const uint32_t size_;
+ T* const records_;
+
+ FOLLY_ALIGN_TO_AVOID_FALSE_SHARING std::atomic<unsigned int> readIndex_;
+ FOLLY_ALIGN_TO_AVOID_FALSE_SHARING std::atomic<unsigned int> writeIndex_;
- std::atomic<unsigned int> readIndex_;
- std::atomic<unsigned int> writeIndex_;
+ char pad1_[CacheLocality::kFalseSharingRange - sizeof(writeIndex_)];
};
}