| 128 | } |
| 129 | |
| 130 | void StaticThreadPool::setMaxTurboThreads(size_t max_threads_turbo_) |
| 131 | { |
| 132 | if (!instance) |
| 133 | throw Exception(ErrorCodes::LOGICAL_ERROR, "The {} is not initialized", name); |
| 134 | |
| 135 | std::lock_guard lock(mutex); |
| 136 | |
| 137 | max_threads_turbo = max_threads_turbo_; |
| 138 | if (turbo_mode_enabled > 0) |
| 139 | instance->setMaxThreads(max_threads_turbo); |
| 140 | } |
| 141 | |
| 142 | /// NOLINTBEGIN(bugprone-macro-parentheses) |
| 143 | #define DEFINE_STATIC_THREAD_POOL_GETTER(SUFFIX, NAME, METRIC) \ |
no test coverage detected