| /third_party/node/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/ |
| D | mergeMap.js | 8 export function mergeMap(project, resultSelector, concurrent) { argument
9 if (concurrent === void 0) {
10 concurrent = Number.POSITIVE_INFINITY;
13 …ect(a, i)).pipe(map(function (b, ii) { return resultSelector(a, b, i, ii); })); }, concurrent)); };
16 concurrent = resultSelector;
18 return function (source) { return source.lift(new MergeMapOperator(project, concurrent)); };
21 function MergeMapOperator(project, concurrent) { argument
22 if (concurrent === void 0) {
23 concurrent = Number.POSITIVE_INFINITY;
26 this.concurrent = concurrent;
[all …]
|
| D | expand.js | 5 export function expand(project, concurrent, scheduler) { argument
6 if (concurrent === void 0) {
7 concurrent = Number.POSITIVE_INFINITY;
12 concurrent = (concurrent || 0) < 1 ? Number.POSITIVE_INFINITY : concurrent;
13 …return function (source) { return source.lift(new ExpandOperator(project, concurrent, scheduler));…
16 function ExpandOperator(project, concurrent, scheduler) { argument
18 this.concurrent = concurrent;
22 …return source.subscribe(new ExpandSubscriber(subscriber, this.project, this.concurrent, this.sched…
29 function ExpandSubscriber(destination, project, concurrent, scheduler) { argument
32 _this.concurrent = concurrent;
[all …]
|
| D | mergeScan.js | 6 export function mergeScan(accumulator, seed, concurrent) { argument
7 if (concurrent === void 0) {
8 concurrent = Number.POSITIVE_INFINITY;
10 …rn function (source) { return source.lift(new MergeScanOperator(accumulator, seed, concurrent)); };
13 function MergeScanOperator(accumulator, seed, concurrent) { argument
16 this.concurrent = concurrent;
19 …ource.subscribe(new MergeScanSubscriber(subscriber, this.accumulator, this.seed, this.concurrent));
26 function MergeScanSubscriber(destination, accumulator, acc, concurrent) { argument
30 _this.concurrent = concurrent;
39 if (this.active < this.concurrent) {
|
| D | mergeMapTo.js | 3 export function mergeMapTo(innerObservable, resultSelector, concurrent) { argument
4 if (concurrent === void 0) {
5 concurrent = Number.POSITIVE_INFINITY;
8 return mergeMap(function () { return innerObservable; }, resultSelector, concurrent);
11 concurrent = resultSelector;
13 return mergeMap(function () { return innerObservable; }, concurrent);
|
| D | mergeAll.js | 4 export function mergeAll(concurrent) { argument
5 if (concurrent === void 0) {
6 concurrent = Number.POSITIVE_INFINITY;
8 return mergeMap(identity, concurrent);
|
| /third_party/node/tools/node_modules/eslint/node_modules/rxjs/internal/operators/ |
| D | mergeMap.js | 21 function mergeMap(project, resultSelector, concurrent) { argument
22 if (concurrent === void 0) { concurrent = Number.POSITIVE_INFINITY; }
24 … i)).pipe(map_1.map(function (b, ii) { return resultSelector(a, b, i, ii); })); }, concurrent)); };
27 concurrent = resultSelector;
29 return function (source) { return source.lift(new MergeMapOperator(project, concurrent)); };
33 function MergeMapOperator(project, concurrent) { argument
34 if (concurrent === void 0) { concurrent = Number.POSITIVE_INFINITY; }
36 this.concurrent = concurrent;
39 return source.subscribe(new MergeMapSubscriber(observer, this.project, this.concurrent));
46 function MergeMapSubscriber(destination, project, concurrent) { argument
[all …]
|
| D | expand.js | 18 function expand(project, concurrent, scheduler) { argument
19 if (concurrent === void 0) { concurrent = Number.POSITIVE_INFINITY; }
21 concurrent = (concurrent || 0) < 1 ? Number.POSITIVE_INFINITY : concurrent;
22 …return function (source) { return source.lift(new ExpandOperator(project, concurrent, scheduler));…
26 function ExpandOperator(project, concurrent, scheduler) { argument
28 this.concurrent = concurrent;
32 …return source.subscribe(new ExpandSubscriber(subscriber, this.project, this.concurrent, this.sched…
39 function ExpandSubscriber(destination, project, concurrent, scheduler) { argument
42 _this.concurrent = concurrent;
47 if (concurrent < Number.POSITIVE_INFINITY) {
[all …]
|
| D | mergeScan.js | 19 function mergeScan(accumulator, seed, concurrent) { argument
20 if (concurrent === void 0) { concurrent = Number.POSITIVE_INFINITY; }
21 …rn function (source) { return source.lift(new MergeScanOperator(accumulator, seed, concurrent)); };
25 function MergeScanOperator(accumulator, seed, concurrent) { argument
28 this.concurrent = concurrent;
31 …ource.subscribe(new MergeScanSubscriber(subscriber, this.accumulator, this.seed, this.concurrent));
38 function MergeScanSubscriber(destination, accumulator, acc, concurrent) { argument
42 _this.concurrent = concurrent;
51 if (this.active < this.concurrent) {
|
| D | mergeMapTo.js | 4 function mergeMapTo(innerObservable, resultSelector, concurrent) { argument
5 if (concurrent === void 0) { concurrent = Number.POSITIVE_INFINITY; }
7 … return mergeMap_1.mergeMap(function () { return innerObservable; }, resultSelector, concurrent);
10 concurrent = resultSelector;
12 return mergeMap_1.mergeMap(function () { return innerObservable; }, concurrent);
|
| D | mergeAll.js | 5 function mergeAll(concurrent) { argument
6 if (concurrent === void 0) { concurrent = Number.POSITIVE_INFINITY; }
7 return mergeMap_1.mergeMap(identity_1.identity, concurrent);
|
| /third_party/node/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/ |
| D | expand.js | 3 export function expand(project, concurrent = Number.POSITIVE_INFINITY, scheduler = undefined) { argument
4 concurrent = (concurrent || 0) < 1 ? Number.POSITIVE_INFINITY : concurrent;
5 return (source) => source.lift(new ExpandOperator(project, concurrent, scheduler));
8 constructor(project, concurrent, scheduler) { argument
10 this.concurrent = concurrent;
14 …return source.subscribe(new ExpandSubscriber(subscriber, this.project, this.concurrent, this.sched…
18 constructor(destination, project, concurrent, scheduler) { argument
21 this.concurrent = concurrent;
26 if (concurrent < Number.POSITIVE_INFINITY) {
41 if (this.active < this.concurrent) {
|
| D | mergeMap.js | 6 export function mergeMap(project, resultSelector, concurrent = Number.POSITIVE_INFINITY) { argument
8 …eMap((a, i) => from(project(a, i)).pipe(map((b, ii) => resultSelector(a, b, i, ii))), concurrent));
11 concurrent = resultSelector;
13 return (source) => source.lift(new MergeMapOperator(project, concurrent));
16 constructor(project, concurrent = Number.POSITIVE_INFINITY) { argument
18 this.concurrent = concurrent;
21 return source.subscribe(new MergeMapSubscriber(observer, this.project, this.concurrent));
25 constructor(destination, project, concurrent = Number.POSITIVE_INFINITY) { argument
28 this.concurrent = concurrent;
35 if (this.active < this.concurrent) {
|
| D | mergeScan.js | 4 export function mergeScan(accumulator, seed, concurrent = Number.POSITIVE_INFINITY) { argument
5 return (source) => source.lift(new MergeScanOperator(accumulator, seed, concurrent));
8 constructor(accumulator, seed, concurrent) { argument
11 this.concurrent = concurrent;
14 …ource.subscribe(new MergeScanSubscriber(subscriber, this.accumulator, this.seed, this.concurrent));
18 constructor(destination, accumulator, acc, concurrent) { argument
22 this.concurrent = concurrent;
30 if (this.active < this.concurrent) {
|
| D | mergeMapTo.js | 2 export function mergeMapTo(innerObservable, resultSelector, concurrent = Number.POSITIVE_INFINITY) { argument
4 return mergeMap(() => innerObservable, resultSelector, concurrent);
7 concurrent = resultSelector;
9 return mergeMap(() => innerObservable, concurrent);
|
| /third_party/python/Lib/asyncio/ |
| D | futures.py | 7 import concurrent.futures
30 """This class is *almost* compatible with concurrent.futures.Future.
43 methods in the concurrent.futures package.
293 if exc_class is concurrent.futures.CancelledError:
295 elif exc_class is concurrent.futures.TimeoutError:
297 elif exc_class is concurrent.futures.InvalidStateError:
303 def _set_concurrent_future_state(concurrent, source): argument
304 """Copy state from a future to a concurrent.futures.Future."""
307 concurrent.cancel()
308 if not concurrent.set_running_or_notify_cancel():
[all …]
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_pq/ |
| D | pq_single_thread_pass.cpp | 29 typedef boost::concurrent::sync_priority_queue<int> sync_pq;
158 boost::concurrent::sync_priority_queue<non_copyable> q; in main()
168 boost::concurrent::sync_priority_queue<non_copyable> q; in main()
180 boost::concurrent::sync_priority_queue<int> q; in main()
191 boost::concurrent::sync_priority_queue<int> q; in main()
200 boost::concurrent::sync_priority_queue<non_copyable> q; in main()
209 boost::concurrent::sync_priority_queue<non_copyable> q; in main()
221 boost::concurrent::sync_priority_queue<int> q; in main()
234 boost::concurrent::sync_priority_queue<non_copyable> q; in main()
249 boost::concurrent::sync_priority_queue<int> q; in main()
[all …]
|
| /third_party/python/Doc/library/ |
| D | concurrent.futures.rst | 1 :mod:`concurrent.futures` --- Launching parallel tasks
4 .. module:: concurrent.futures
9 **Source code:** :source:`Lib/concurrent/futures/thread.py`
10 and :source:`Lib/concurrent/futures/process.py`
14 The :mod:`concurrent.futures` module provides a high-level interface for
50 The returned iterator raises a :exc:`concurrent.futures.TimeoutError`
143 pending jobs will raise a :exc:`~concurrent.futures.thread.BrokenThreadPool`,
178 import concurrent.futures
193 with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
196 for future in concurrent.futures.as_completed(future_to_url):
[all …]
|
| D | concurrency.rst | 4 Concurrent Execution
7 The modules described in this chapter provide support for concurrent
19 concurrent.rst
20 concurrent.futures.rst
|
| /third_party/Linux_Kernel/include/linux/ |
| D | kfifo.h | 233 * from the reader thread and there is only one concurrent reader. Otherwise
384 * Note that with only one concurrent reader and one concurrent
421 * Note that with only one concurrent reader and one concurrent
460 * Note that with only one concurrent reader and one concurrent
498 * Note that with only one concurrent reader and one concurrent
546 * Note that with only one concurrent reader and one concurrent
599 * Note that with only one concurrent reader and one concurrent
627 * Note that with only one concurrent reader and one concurrent
655 * Note that with only one concurrent reader and one concurrent
679 * Note that with only one concurrent reader and one concurrent
[all …]
|
| /third_party/grpc/test/core/tsi/alts/handshaker/ |
| D | alts_concurrent_connectivity_test.cc | 85 // The main goal of these tests are to stress concurrent ALTS handshakes, in create_secure_channel_for_test()
111 …FakeHandshakerService(kFakeHandshakeServerMaxConcurrentStreams /* expected max concurrent rpcs */); in FakeHandshakeServer()
114 0 /* expected max concurrent rpcs unset */); in FakeHandshakeServer()
120 // TODO(apolcyn): when removing the global concurrent handshake limiting in FakeHandshakeServer()
142 : fake_handshake_server_(true /* check num concurrent rpcs */) { in TestServer()
288 true /* check num concurrent rpcs */); in TEST()
299 /* Run a bunch of concurrent ALTS handshakes on concurrent channels
303 true /* check num concurrent rpcs */); in TEST()
311 "start performing concurrent expected-to-succeed connects"); in TEST()
322 "done performing concurrent expected-to-succeed connects"); in TEST()
[all …]
|
| /third_party/node/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/observable/ |
| D | merge.js | 6 let concurrent = Number.POSITIVE_INFINITY;
12 concurrent = observables.pop();
16 concurrent = observables.pop();
21 return mergeAll(concurrent)(fromArray(observables, scheduler));
|
| /third_party/ejdb/src/bindings/ejdb2_react_native/binding/android/src/main/java/com/softmotions/ejdb2/ |
| D | EJDB2Package.java | 7 import java.util.concurrent.Executor;
8 import java.util.concurrent.SynchronousQueue;
9 import java.util.concurrent.ThreadPoolExecutor;
10 import java.util.concurrent.TimeUnit;
|
| /third_party/node/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/observable/ |
| D | merge.js | 11 var concurrent = Number.POSITIVE_INFINITY;
17 concurrent = observables.pop();
21 concurrent = observables.pop();
26 return mergeAll(concurrent)(fromArray(observables, scheduler));
|
| /third_party/node/tools/node_modules/eslint/node_modules/rxjs/internal/observable/ |
| D | merge.js | 12 var concurrent = Number.POSITIVE_INFINITY;
18 concurrent = observables.pop();
22 concurrent = observables.pop();
27 return mergeAll_1.mergeAll(concurrent)(fromArray_1.fromArray(observables, scheduler));
|
| /third_party/boost/libs/lockfree/doc/ |
| D | lockfree.qbk | 7 lockfree concurrent data structures
36 The term *non-blocking* denotes concurrent data structures, which do not use traditional synchroniz…
41 * data structures are *wait-free*, if every concurrent operation is guaranteed to be finished in a …
44 * data structures are *lock-free*, if some concurrent operations are guaranteed to be finished in a…
48 * data structures are *obstruction-free*, if a concurrent operation is guaranteed to be finished in…
49 steps, unless another concurrent operation interferes.
54 (*sp*) or *multiple producer* (*mp*) means that only a single thread or multiple concurrent threads…
79 application one should consider high-performance concurrent data structures [footnote
80 …ks.org/ Intel's Thread Building Blocks library] provides many efficient concurrent data structures,
85 concurrent data structures are sufficient. In any case we advice to perform benchmarks with differe…
[all …]
|