/* * Copyright 2019 The libgav1 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 LIBGAV1_SRC_UTILS_BLOCKING_COUNTER_H_ #define LIBGAV1_SRC_UTILS_BLOCKING_COUNTER_H_ #include <cassert> #include <condition_variable> // NOLINT (unapproved c++11 header) #include <mutex> // NOLINT (unapproved c++11 header) #include "src/utils/compiler_attributes.h" namespace libgav1 { // Implementation of a Blocking Counter that is used for the "fork-join" // use case. Typical usage would be as follows: // BlockingCounter counter(num_jobs); // - spawn the jobs. // - call counter.Wait() on the master thread. // - worker threads will call counter.Decrement(). // - master thread will return from counter.Wait() when all workers are // complete. template <bool has_failure_status> class BlockingCounterImpl { … }; BlockingCounterWithStatus; BlockingCounter; } // namespace libgav1 #endif // LIBGAV1_SRC_UTILS_BLOCKING_COUNTER_H_