diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-12-09 12:44:04 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-12-09 12:44:04 +0000 |
commit | f494c15549608e814b61707928168e6d117e5065 (patch) | |
tree | 55f3b238579102730240f473beb9ac33f8e96566 /staging_vespalib | |
parent | 800c53c580717f7f1d8bcc02d31235ac6d3673d2 (diff) |
Reduce watermark from 50% to 10% to get faster reaction.
Diffstat (limited to 'staging_vespalib')
-rw-r--r-- | staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.cpp b/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.cpp index db27c13463f..76b0235301b 100644 --- a/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.cpp +++ b/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.cpp @@ -66,7 +66,7 @@ SequencedTaskExecutor::create(Runnable::init_fun_t func, uint32_t threads, uint3 executors.reserve(threads); for (uint32_t id = 0; id < threads; ++id) { if (optimize == OptimizeFor::THROUGHPUT) { - uint32_t watermark = kindOfWatermark == 0 ? taskLimit / 2 : kindOfWatermark; + uint32_t watermark = (kindOfWatermark == 0) ? taskLimit / 10 : kindOfWatermark; executors.push_back(std::make_unique<SingleExecutor>(func, taskLimit, watermark, 100ms)); } else { executors.push_back(std::make_unique<BlockingThreadStackExecutor>(1, stackSize, taskLimit, func)); |