| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-utils/src/sync/ |
| D | wait_group.rs | 46 pub struct WaitGroup { struct
50 /// Inner state of a `WaitGroup`. argument
56 impl Default for WaitGroup { implementation
67 impl WaitGroup { impl
118 impl Drop for WaitGroup { implementation
129 impl Clone for WaitGroup { implementation
130 fn clone(&self) -> WaitGroup { in clone()
140 impl fmt::Debug for WaitGroup { implementation
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/sync/ |
| D | waitgroup.go | 25 type WaitGroup struct { struct
26 noCopy noCopy
28 state atomic.Uint64 // high 32 bits are counter, low 32 bits are waiter count.
29 sema uint32
45 func (wg *WaitGroup) Add(delta int) {
88 func (wg *WaitGroup) Done() {
93 func (wg *WaitGroup) Wait() {
|
| D | waitgroup_test.go | 13 func testWaitGroup(t *testing.T, wg1 *WaitGroup, wg2 *WaitGroup) {
|
| /aosp_15_r20/prebuilts/go/linux-x86/test/fixedbugs/issue19467.dir/ |
| D | mysync.go | 9 type WaitGroup struct { struct
10 Callers []uintptr
13 func (wg *WaitGroup) Add(x int) {
19 func (wg *WaitGroup) Done() {
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/runtime/testdata/testprogcgo/ |
| D | eintr.go | 112 func testPipe(wg *sync.WaitGroup) {
159 func testNet(wg *sync.WaitGroup) {
218 func testExec(wg *sync.WaitGroup) {
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/runtime/pprof/ |
| D | pprof_test.go | 2677 func inlineA(mu *sync.Mutex, wg *sync.WaitGroup) { inlineB(mu, wg) }
2678 func inlineB(mu *sync.Mutex, wg *sync.WaitGroup) { inlineC(mu, wg) }
2679 func inlineC(mu *sync.Mutex, wg *sync.WaitGroup) {
2685 func inlineD(mu *sync.Mutex, wg *sync.WaitGroup) { inlineE(mu, wg) }
2686 func inlineE(mu *sync.Mutex, wg *sync.WaitGroup) { inlineF(mu, wg) }
2687 func inlineF(mu *sync.Mutex, wg *sync.WaitGroup) {
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/cmd/trace/testdata/testprog/ |
| D | main.go | 97 func cpu10(wg *sync.WaitGroup) {
102 func cpu20(wg *sync.WaitGroup) {
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/cmd/dist/ |
| D | util.go | 163 func bgrun(wg *sync.WaitGroup, dir string, cmd ...string) {
173 func bgwait(wg *sync.WaitGroup) {
|
| /aosp_15_r20/hardware/google/gfxstream/guest/android-emu/aemu/base/threads/ |
| D | AndroidWorkPool.cpp | 39 class WaitGroup { // intrusive refcounted class
42 WaitGroup(int numTasksRemaining) : in WaitGroup() function in gfxstream::guest::WaitGroup
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/cmd/compile/internal/ssa/testdata/ |
| D | sayhi.go | 8 func sayhi(n int, wg *sync.WaitGroup) {
|
| /aosp_15_r20/external/swiftshader/third_party/marl/src/ |
| H A D | waitgroup_bench.cpp | 19 BENCHMARK_DEFINE_F(Schedule, WaitGroup)(benchmark::State& state) { in BENCHMARK_DEFINE_F() argument
|
| /aosp_15_r20/external/swiftshader/third_party/marl/include/marl/ |
| H A D | parallelize.h | 25 MARL_NO_EXPORT inline void parallelizeChain(WaitGroup&) {} in parallelizeChain() argument
|
| H A D | waitgroup.h | 80 WaitGroup::WaitGroup(unsigned int initialCount /* = 0 */, in WaitGroup() function
|
| /aosp_15_r20/external/cronet/third_party/boringssl/src/util/pregenerate/ |
| H A D | pregenerate.go | 81 func worker(taskChan <-chan Task, errorChan chan<- taskError, wg *sync.WaitGroup) {
|
| /aosp_15_r20/external/boringssl/src/util/pregenerate/ |
| H A D | pregenerate.go | 81 func worker(taskChan <-chan Task, errorChan chan<- taskError, wg *sync.WaitGroup) {
|
| /aosp_15_r20/development/tools/repo_diff/service/repodiff/interactors/ |
| H A D | runner.go | 12 sync.WaitGroup anonMember
|
| /aosp_15_r20/external/cronet/third_party/boringssl/src/util/fipstools/acvp/acvptool/test/ |
| H A D | check_expected.go | 135 func worker(wg *sync.WaitGroup, work <-chan invocation, numFailed *uint32) {
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| H A D | test_common.py | 119 class WaitGroup(object): class
|
| /aosp_15_r20/external/boringssl/src/util/fipstools/acvp/acvptool/test/ |
| H A D | check_expected.go | 135 func worker(wg *sync.WaitGroup, work <-chan invocation, numFailed *uint32) {
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/log/syslog/ |
| D | syslog_test.go | 60 func runStreamSyslog(l net.Listener, done chan<- string, wg *sync.WaitGroup) {
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-channel/tests/ |
| D | golang.rs | 164 struct WaitGroup(Arc<WaitGroupInner>); struct
171 impl WaitGroup { impl
|
| /aosp_15_r20/external/cronet/third_party/boringssl/src/util/ |
| H A D | all_tests.go | 265 func worker(tests <-chan test, results chan<- result, done *sync.WaitGroup) {
|
| /aosp_15_r20/external/boringssl/src/util/ |
| H A D | all_tests.go | 274 func worker(tests <-chan test, results chan<- result, done *sync.WaitGroup) {
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/runtime/ |
| D | gc_test.go | 749 func countpwg(n *int, ready *sync.WaitGroup, teardown chan bool) {
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/cmd/link/internal/ld/ |
| D | data.go | 1120 func writeParallel(wg *sync.WaitGroup, fn writeFn, ctxt *Link, seek, vaddr, length uint64) {
|