mirror of https://github.com/grpc/grpc.git
[event_engine] Improve scaling in threadpool (#31234)
* fixes * Automated change: Fix sanity tests * fix * fix * fix * fix * fixes * fixes * fix * fix-win * fix iwyu * fix * fix Co-authored-by: ctiller <ctiller@users.noreply.github.com>pull/31242/head
Craig Tiller
2 years ago
committed by
GitHub
parent
3c96517fc0
commit
2d00d50c59
27 changed files with 178 additions and 197 deletions
@ -1,36 +0,0 @@ |
||||
// Copyright 2022 gRPC authors.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
// See the License for the specific language governing permissions and
|
||||
// limitations under the License.
|
||||
|
||||
#include <grpc/support/port_platform.h> |
||||
|
||||
#include "src/core/lib/event_engine/executor/threaded_executor.h" |
||||
|
||||
#include <utility> |
||||
|
||||
namespace grpc_event_engine { |
||||
namespace experimental { |
||||
|
||||
ThreadedExecutor::ThreadedExecutor(int reserve_threads) |
||||
: thread_pool_(reserve_threads){}; |
||||
|
||||
void ThreadedExecutor::Run(EventEngine::Closure* closure) { |
||||
thread_pool_.Add([closure]() { closure->Run(); }); |
||||
} |
||||
|
||||
void ThreadedExecutor::Run(absl::AnyInvocable<void()> closure) { |
||||
thread_pool_.Add(std::move(closure)); |
||||
} |
||||
|
||||
} // namespace experimental
|
||||
} // namespace grpc_event_engine
|
||||
@ -1,44 +0,0 @@ |
||||
// Copyright 2022 gRPC authors.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
// See the License for the specific language governing permissions and
|
||||
// limitations under the License.
|
||||
|
||||
#ifndef GRPC_CORE_LIB_EVENT_ENGINE_EXECUTOR_THREADED_EXECUTOR_H |
||||
#define GRPC_CORE_LIB_EVENT_ENGINE_EXECUTOR_THREADED_EXECUTOR_H |
||||
|
||||
#include <grpc/support/port_platform.h> |
||||
|
||||
#include "absl/functional/any_invocable.h" |
||||
|
||||
#include <grpc/event_engine/event_engine.h> |
||||
|
||||
#include "src/core/lib/event_engine/executor/executor.h" |
||||
#include "src/core/lib/event_engine/thread_pool.h" |
||||
|
||||
namespace grpc_event_engine { |
||||
namespace experimental { |
||||
|
||||
class ThreadedExecutor : public Executor { |
||||
public: |
||||
explicit ThreadedExecutor(int reserve_threads); |
||||
~ThreadedExecutor() override = default; |
||||
void Run(EventEngine::Closure* closure) override; |
||||
void Run(absl::AnyInvocable<void()> closure) override; |
||||
|
||||
private: |
||||
ThreadPool thread_pool_; |
||||
}; |
||||
|
||||
} // namespace experimental
|
||||
} // namespace grpc_event_engine
|
||||
|
||||
#endif // GRPC_CORE_LIB_EVENT_ENGINE_EXECUTOR_THREADED_EXECUTOR_H
|
||||
Loading…
Reference in new issue