mirror of
https://github.com/opencv/opencv.git
synced 2025-06-13 13:13:26 +08:00
8e43c8f200
G-API: Implement concurrent executor #24845 ## Overview This PR introduces the new G-API executor called `GThreadedExecutor` which can be selected when the `GComputation` is compiled in `serial` mode (a.k.a `GComputation::compile(...)`) ### ThreadPool `cv::gapi::own::ThreadPool` has been introduced in order to abstract usage of threads in `GThreadedExecutor`. `ThreadPool` is implemented by using `own::concurrent_bounded_queue` `ThreadPool` has only as single method `schedule` that will push task into the queue for the further execution. The **important** notice is that if `Task` executed in `ThreadPool` throws exception - this is `UB`. ### GThreadedExecutor The `GThreadedExecutor` is mostly copy-paste of `GExecutor`, should we extend `GExecutor` instead? #### Implementation details 1. Build the dependency graph for `Island` nodes. 2. Store the tasks that don't have dependencies into separate `vector` in order to run them first. 3. at the `GThreadedExecutor::run()` schedule the tasks that don't have dependencies that will schedule their dependents and wait for the completion. ### Pull Request Readiness Checklist See details at https://github.com/opencv/opencv/wiki/How_to_contribute#making-a-good-pull-request - [ ] I agree to contribute to the project under Apache 2 License. - [ ] To the best of my knowledge, the proposed patch is not based on a code under GPL or another license that is incompatible with OpenCV - [ ] The PR is proposed to the proper branch - [ ] There is a reference to the original bug report and related work - [ ] There is accuracy test, performance test and test data in opencv_extra repository, if applicable Patch to opencv_extra has the same branch name. - [ ] The feature is well documented and sample code can be built with the project CMake |
||
|---|---|---|
| .. | ||
| cpu | ||
| fluid | ||
| gpu | ||
| infer | ||
| oak | ||
| ocl | ||
| own | ||
| plaidml | ||
| python | ||
| render | ||
| s11n | ||
| streaming | ||
| util | ||
| core.hpp | ||
| garg.hpp | ||
| garray.hpp | ||
| gasync_context.hpp | ||
| gcall.hpp | ||
| gcommon.hpp | ||
| gcompiled_async.hpp | ||
| gcompiled.hpp | ||
| gcompoundkernel.hpp | ||
| gcomputation_async.hpp | ||
| gcomputation.hpp | ||
| gframe.hpp | ||
| gkernel.hpp | ||
| gmat.hpp | ||
| gmetaarg.hpp | ||
| gopaque.hpp | ||
| gproto.hpp | ||
| gscalar.hpp | ||
| gstreaming.hpp | ||
| gtransform.hpp | ||
| gtype_traits.hpp | ||
| gtyped.hpp | ||
| imgproc.hpp | ||
| infer.hpp | ||
| media.hpp | ||
| opencv_includes.hpp | ||
| operators.hpp | ||
| ot.hpp | ||
| render.hpp | ||
| rmat.hpp | ||
| s11n.hpp | ||
| stereo.hpp | ||
| video.hpp | ||