+ if (FLAGS_observer_manager_pool_size < 1) {
+ LOG(ERROR) << "--observer_manager_pool_size should be >= 1";
+ FLAGS_observer_manager_pool_size = 1;
+ }
+ for (int32_t i = 0; i < FLAGS_observer_manager_pool_size; ++i) {
+ threads_.emplace_back([this, i]() {
+ folly::setThreadName(
+ folly::sformat("{}{}", kObserverManagerThreadNamePrefix, i));