| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/ |
| D | queue.h | 73 std::unique_lock<std::mutex> _lock(mux_); in Add()
75 Status rc = full_cv_.Wait(&_lock, [this]() -> bool { return (size() != capacity()); }); in Add()
80 _lock.unlock(); in Add()
88 std::unique_lock<std::mutex> _lock(mux_); in Add()
90 Status rc = full_cv_.Wait(&_lock, [this]() -> bool { return (size() != capacity()); }); in Add()
95 _lock.unlock(); in Add()
104 std::unique_lock<std::mutex> _lock(mux_); in EmplaceBack()
106 Status rc = full_cv_.Wait(&_lock, [this]() -> bool { return (size() != capacity()); }); in EmplaceBack()
111 _lock.unlock(); in EmplaceBack()
120 std::unique_lock<std::mutex> _lock(mux_); in PopFront()
[all …]
|
| /third_party/python/Lib/multiprocessing/ |
| D | synchronize.py | 213 self._lock = lock or ctx.RLock()
221 return (self._lock, self._sleeping_count,
225 (self._lock, self._sleeping_count,
230 return self._lock.__enter__()
233 return self._lock.__exit__(*args)
236 self.acquire = self._lock.acquire
237 self.release = self._lock.release
245 return '<%s(%s, %s)>' % (self.__class__.__name__, self._lock, num_waiters)
248 assert self._lock._semlock._is_mine(), \
255 count = self._lock._semlock._count()
[all …]
|
| D | sharedctypes.py | 185 self._lock = lock
188 self._lock = ctx.RLock()
189 self.acquire = self._lock.acquire
190 self.release = self._lock.release
193 return self._lock.__enter__()
196 return self._lock.__exit__(*args)
200 return synchronized, (self._obj, self._lock)
206 return self._lock
|
| D | resource_sharer.py | 66 self._lock = threading.Lock()
74 with self._lock:
93 with self._lock:
115 self._lock._at_fork_reinit()
|
| D | util.py | 370 self._lock = threading.Lock()
371 self.acquire = self._lock.acquire
372 self.release = self._lock.release
376 self._lock._at_fork_reinit()
379 return self._lock.__enter__()
382 return self._lock.__exit__(*args)
|
| D | resource_tracker.py | 57 self._lock = threading.Lock()
62 with self._lock:
83 with self._lock:
|
| D | heap.py | 125 self._lock = threading.Lock()
282 if not self._lock.acquire(False):
294 self._lock.release()
304 with self._lock:
|
| D | forkserver.py | 39 self._lock = threading.Lock()
44 with self._lock:
112 with self._lock:
|
| /third_party/python/Lib/ |
| D | sched.py | 57 self._lock = threading.RLock()
72 with self._lock:
94 with self._lock:
100 with self._lock:
129 lock = self._lock
165 with self._lock:
|
| D | threading.py | 239 self._lock = lock
261 self._lock._at_fork_reinit()
265 return self._lock.__enter__()
268 return self._lock.__exit__(*args)
271 return "<Condition(%s, %d)>" % (self._lock, len(self._waiters))
274 self._lock.release() # No state to save
277 self._lock.acquire() # Ignore saved state
282 if self._lock.acquire(False):
283 self._lock.release()
|
| D | webbrowser.py | 17 _lock = threading.RLock() variable
24 with _lock:
40 with _lock:
81 with _lock:
|
| /third_party/grpc/src/python/grpcio_health_checking/grpc_health/v1/ |
| D | health.py | 87 self._lock = threading.RLock()
97 with self._lock:
105 with self._lock:
124 with self._lock:
145 with self._lock:
165 with self._lock:
|
| /third_party/grpc/src/python/grpcio_tests/tests/qps/ |
| D | histogram.py | 28 self._lock = threading.Lock()
40 with self._lock:
49 with self._lock:
58 with self._lock:
69 with self._lock:
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | thread_pool.py | 24 self._lock = threading.Lock()
28 with self._lock:
33 with self._lock:
|
| D | _metadata_code_details_test.py | 64 self._lock = threading.Lock()
73 with self._lock:
90 with self._lock:
107 with self._lock:
127 with self._lock:
147 with self._lock:
151 with self._lock:
155 with self._lock:
159 with self._lock:
163 with self._lock:
[all …]
|
| D | _server_ssl_cert_config_test.py | 88 self._lock = threading.Lock()
94 with self._lock:
103 with self._lock:
108 with self._lock:
112 with self._lock:
|
| /third_party/grpc/src/python/grpcio/grpc/framework/foundation/ |
| D | stream_util.py | 88 self._lock = threading.Lock()
109 with self._lock:
124 with self._lock:
133 with self._lock:
141 with self._lock:
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/framework/foundation/ |
| D | _logging_pool_test.py | 27 self._lock = threading.Lock()
31 with self._lock:
35 with self._lock:
|
| /third_party/grpc/src/python/grpcio/grpc/ |
| D | _simple_stubs.py | 75 _lock: threading.RLock = threading.RLock() variable in ChannelCache
76 _condition: threading.Condition = threading.Condition(lock=_lock)
90 with ChannelCache._lock:
106 with ChannelCache._lock:
145 with self._lock:
164 with self._lock:
|
| /third_party/grpc/examples/python/errors/ |
| D | server.py | 49 self._lock = threading.RLock()
53 with self._lock:
|
| /third_party/iowow/src/kv/ |
| D | iwal.c | 62 IW_INLINE iwrc _lock(IWAL *wal) { in _lock() function
85 rc = _lock(wal); in _excl_lock()
194 iwrc rc = _lock(wal); in _write_op()
203 iwrc rc = _lock(wal); in iwal_sync()
286 iwrc rc = _lock(wal); in _onresize()
301 iwrc rc = _lock(wal); in _onsynced()
680 iwrc rc = _lock(wal); in iwal_poke_checkpoint()
705 iwrc rc = _lock(wal); in iwal_poke_savepoint()
789 rc = _lock(wal); in _cpt_worker_fn()
872 rc = _lock(wal); in iwal_online_backup()
[all …]
|
| /third_party/flutter/flutter/packages/flutter_goldens_client/lib/ |
| D | client.dart | 75 RandomAccessFile _lock;
183 _lock = await lockFile.open(mode: io.FileMode.write);
184 await _lock.lock(io.FileLock.blockingExclusive);
188 await _lock.close();
189 _lock = null;
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _cancel_many_calls_test.py | 56 self._lock = threading.Lock()
68 with self._lock:
79 with self._lock:
|
| /third_party/boost/boost/outcome/experimental/status-code/ |
| D | std_error_code.hpp | 142 std::atomic<unsigned> _lock; in std_error_code_domain_from_category() member
156 while(_lock.exchange(1, std::memory_order_acquire) != 0) in std_error_code_domain_from_category()
159 void unlock() { _lock.store(0, std::memory_order_release); } in std_error_code_domain_from_category()
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_pep492.py | 56 async with lock as _lock:
57 self.assertIs(_lock, None)
|