| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Merge.kt | 26 * Default concurrency limit that is used by [flattenMerge] and [flatMapMerge] operators. in <lambda>()
53 … operator calls [transform] *sequentially* and then merges the resulting flows with a [concurrency] in <lambda>()
55 * It is a shortcut for `map(transform).flattenMerge(concurrency)`. in <lambda>()
66 …* @param concurrency controls the number of in-flight flows, at most [concurrency] flows are colle… in <lambda>()
71 concurrency: Int = DEFAULT_CONCURRENCY, in <lambda>()
74 map(transform).flattenMerge(concurrency) in <lambda>()
121 * Flattens the given flow of flows into a single flow with a [concurrency] limit on the number of in merge()
124 * If [concurrency] is more than 1, then inner flows are collected by this operator *concurrently*. in merge()
125 * With `concurrency == 1` this operator is identical to [flattenConcat]. in merge()
132 * When [concurrency] is greater than 1, this operator is [buffered][buffer] by default in merge()
[all …]
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/ |
| D | FlowFlattenMergeBenchmark.kt | 28 private var concurrency: Int = 0 in <lambda>() variable in benchmarks.flow.FlowFlattenMergeBenchmark
34 val n = flowsNumberStrategy.get(concurrency) in <lambda>()
49 flow.flattenMerge(concurrency = concurrency).collect() in <lambda>()
53 enum class FlowsNumberStrategy(val get: (concurrency: Int) -> Int) {
54 `10xConcurrency flows`({ concurrency -> concurrency * 10 }), in concurrency() method
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Uninterruptibles.java | 55 @GwtIncompatible // concurrency
81 @GwtIncompatible // concurrency
91 @GwtIncompatible // concurrency
121 @GwtIncompatible // concurrency
132 @GwtIncompatible // concurrency
156 @GwtIncompatible // concurrency
181 @GwtIncompatible // concurrency
190 @GwtIncompatible // concurrency
325 @GwtIncompatible // concurrency
351 @GwtIncompatible // concurrency
[all …]
|
| /external/kotlinx.coroutines/benchmarks/scripts/ |
| D | generate_plots_flow_flatten_merge.py | 15 csv_columns = ["Benchmark", "Score", "Unit", "Param: concurrency", "Param: flowsNumberStrategy"]
17 "Param: concurrency" : "concurrency", "Param: flowsNumberStrategy" : "flows"}
42 plt.xlabel('concurrency')
43 plt.xticks(data.concurrency.unique())
51 # plt.plot(res.concurrency, res.score*elements/1000, label="flows={}".format(flows), color=…
52 …plt.errorbar(x=res.concurrency, y=res.score*elements/1000, yerr=res.score_error*elements/1000, sol…
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | Uninterruptibles.java | 53 @GwtIncompatible // concurrency
77 @GwtIncompatible // concurrency
107 @GwtIncompatible // concurrency
131 @GwtIncompatible // concurrency
154 @GwtIncompatible // concurrency
262 @GwtIncompatible // concurrency
288 @GwtIncompatible // concurrency
309 @GwtIncompatible // concurrency
339 @GwtIncompatible // concurrency
352 @GwtIncompatible // concurrency
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | Merge.kt | 43 private val concurrency: Int, constant in ChannelFlowMerge
49 ChannelFlowMerge(flow, concurrency, context, capacity, onBufferOverflow) in create()
56 val semaphore = Semaphore(concurrency) in collectTo()
71 semaphore.release() // Release concurrency permit in collectTo()
77 override fun additionalToStringProps(): String = "concurrency=$concurrency" in additionalToStringProps()
|
| /external/kotlinx.coroutines/docs/ |
| D | shared-mutable-state-and-concurrency.md | 1 ….org/docs/shared-mutable-state-and-concurrency.html](https://kotlinlang.org/docs/shared-mutable-st…
3 …ion, open the [topics/shared-mutable-state-and-concurrency.md](topics/shared-mutable-state-and-con…
|
| /external/cronet/buildtools/third_party/libc++/trunk/docs/Helpers/ |
| D | Styles.rst | 25 .concurrency { background-color: #909090; white-space:nowrap; }
47 .. role:: concurrency
54 .. |concurrency TS| replace:: :concurrency:`concurrency TS`
|
| /external/linux-kselftest/tools/testing/selftests/tc-testing/tc-tests/filters/ |
| D | concurrency.json | 8 "concurrency"
31 "concurrency"
56 "concurrency"
81 "concurrency"
106 "concurrency"
131 "concurrency"
157 "concurrency"
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | FlatMapStressTest.kt | 89 val concurrency = AtomicLong() in <lambda>() constant
90 val result = (1L..iterations).asFlow().flatMapMerge(concurrency = maxConcurrency) { value -> in <lambda>()
92 val current = concurrency.incrementAndGet() in <lambda>()
95 concurrency.decrementAndGet() in <lambda>()
99 assertEquals(0, concurrency.get()) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | DefaultDispatchersTest.kt | 66 val concurrency = AtomicInteger() in <lambda>() constant
69 val c = concurrency.incrementAndGet() in <lambda>()
71 concurrency.decrementAndGet() in <lambda>()
|
| /external/grpc-grpc/src/ruby/end2end/ |
| D | grpc_class_init_driver.rb | 30 ['', 'gc', 'concurrency'].each do |stress_test_type|
53 # concurrency stress test type is expected to exit with a
55 if client_exit_code != 0 && stress_test_type != 'concurrency'
|
| /external/rust/crates/crossbeam-epoch/ |
| D | Cargo.toml.orig | 15 categories = ["concurrency", "memory-management", "no-std"]
39 # Enable the use of loom for concurrency testing.
53 # Enable the use of loom for concurrency testing.
|
| /external/apache-commons-bcel/docs/ |
| D | generic.mdl | 68 concurrency "Sequential"
73 concurrency "Sequential"
87 concurrency "Sequential"
97 concurrency "Sequential"
105 concurrency "Sequential"
120 concurrency "Sequential"
126 concurrency "Sequential"
140 concurrency "Sequential"
200 concurrency "Sequential"
238 concurrency "Sequential"
[all …]
|
| /external/javaparser/javaparser-symbol-solver-testing/src/test/resources/ |
| D | PlatformTestUtil.java.txt | 53 import com.intellij.util.concurrency.AppExecutorUtil;
54 import com.intellij.util.concurrency.AppScheduledExecutorService;
65 import org.jetbrains.concurrency.AsyncPromise;
66 import org.jetbrains.concurrency.Promise;
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | MapMaker.java | 135 * is {@code 60}, and the concurrency level is {@code 8}, then eight segments are created, each
159 * Guides the allowed concurrency among update operations. Used as a hint for internal sizing. The
162 * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
168 * concurrency than full synchronization. Defaults to 4.
175 * @throws IllegalStateException if a concurrency level was already set
181 "concurrency level was already set to %s", in concurrencyLevel()
|
| /external/guava/android/guava/src/com/google/common/collect/ |
| D | MapMaker.java | 135 * is {@code 60}, and the concurrency level is {@code 8}, then eight segments are created, each
159 * Guides the allowed concurrency among update operations. Used as a hint for internal sizing. The
162 * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
168 * concurrency than full synchronization. Defaults to 4.
175 * @throws IllegalStateException if a concurrency level was already set
181 "concurrency level was already set to %s", in concurrencyLevel()
|
| /external/cronet/components/cronet/android/test/javaperftests/src/org/chromium/net/ |
| D | CronetPerfTestActivity.java | 82 Mode mode, Direction direction, Protocol protocol, int concurrency, int iterations) { in buildBenchmarkName() argument
94 name += iterations + "_" + concurrency + "_"; in buildBenchmarkName()
141 * @param concurrency The number of transfers to perform concurrently.
146 int concurrency, JSONObject results) { in Benchmark() argument
213 mName = buildBenchmarkName(mode, direction, protocol, concurrency, mIterations); in Benchmark()
214 mConcurrency = concurrency; in Benchmark()
577 // Also run them four at a time to see how they benefit from concurrency. in onCreate()
585 // further increased concurrency to see if further benefit is possible. in onCreate()
|
| /external/kotlinx.coroutines/docs/topics/ |
| D | coroutines-basics.md | 71 ### Structured concurrency
74 **structured concurrency** which means that new coroutines can only be launched in a specific [Coro…
78 In a real application, you will be launching a lot of coroutines. Structured concurrency ensures th…
80 Structured concurrency also ensures that any errors in the code are properly reported and are never…
162 ## Scope builder and concurrency
|
| /external/rust/crates/rayon/ |
| D | Cargo.toml.orig | 13 keywords = ["parallel", "thread", "concurrency", "join", "performance"]
14 categories = ["concurrency"]
|
| D | Cargo.toml | 33 "concurrency",
37 categories = ["concurrency"]
|
| /external/rust/crates/rayon-core/ |
| D | Cargo.toml.orig | 15 keywords = ["parallel", "thread", "concurrency", "join", "performance"]
16 categories = ["concurrency"]
|
| /external/guava/android/guava-testlib/test/com/google/common/testing/ |
| D | FakeTickerTest.java | 103 @GwtIncompatible // concurrency
125 @GwtIncompatible // concurrency
147 @GwtIncompatible // concurrency
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/framework/common/ |
| D | test_constants.py | 36 # The concurrency to use in tests of concurrent RPCs that will not create as
40 # The concurrency to use in tests of concurrent RPCs that will create as many
|
| /external/rust/crates/crossbeam-utils/ |
| D | Cargo.toml.orig | 15 categories = ["algorithms", "concurrency", "data-structures", "no-std"]
36 # Enable the use of loom for concurrency testing.
|