| /external/Reactive-Extensions/RxCpp/Ix/CPP/samples/SampleCppLinq/ |
| D | data.txt | 1 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22437888.0, '…
2 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22626304.0, '…
3 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22503424.0, '…
4 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22667264.0, '…
5 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22323200.0, '…
6 {'var': [('concurrency', 1), ('args', '-test ums-gated')], 'result': {'workingset': 14917632.0, 'pr…
7 {'var': [('concurrency', 1), ('args', '-test ums-gated')], 'result': {'workingset': 15060992.0, 'pr…
8 {'var': [('concurrency', 1), ('args', '-test ums-gated')], 'result': {'workingset': 15052800.0, 'pr…
9 {'var': [('concurrency', 1), ('args', '-test ums-gated')], 'result': {'workingset': 14934016.0, 'pr…
10 {'var': [('concurrency', 1), ('args', '-test ums-gated')], 'result': {'workingset': 14991360.0, 'pr…
[all …]
|
| D | SampleCppLinq.cpp | 31 int concurrency; in run() member
36 concurrency = atoi( extract_value(input, "concurrency").c_str() ); in run()
59 cout << "concurrency, mean, |, raw_data," << endl; in run()
62 .groupby([](const item& i) { return i.concurrency; }); in run()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Merge.kt | 25 * Default concurrency limit that is used by [flattenMerge] and [flatMapMerge] operators. in <lambda>()
50 … operator calls [transform] *sequentially* and then merges the resulting flows with a [concurrency] in <lambda>()
52 * It is a shortcut for `map(transform).flattenMerge(concurrency)`. in <lambda>()
63 …* @param concurrency controls the number of in-flight flows, at most [concurrency] flows are colle… in <lambda>()
68 concurrency: Int = DEFAULT_CONCURRENCY, in <lambda>()
71 map(transform).flattenMerge(concurrency) in <lambda>()
118 * Flattens the given flow of flows into a single flow with a [concurrency] limit on the number of in merge()
121 * If [concurrency] is more than 1, then inner flows are collected by this operator *concurrently*. in merge()
122 * With `concurrency == 1` this operator is identical to [flattenConcat]. in merge()
129 * 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 | 56 @GwtIncompatible // concurrency
82 @GwtIncompatible // concurrency
93 @GwtIncompatible // concurrency
123 @GwtIncompatible // concurrency
135 @GwtIncompatible // concurrency
159 @GwtIncompatible // concurrency
184 @GwtIncompatible // concurrency
194 @GwtIncompatible // concurrency
330 @GwtIncompatible // concurrency
356 @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 | 54 @GwtIncompatible // concurrency
78 @GwtIncompatible // concurrency
108 @GwtIncompatible // concurrency
132 @GwtIncompatible // concurrency
155 @GwtIncompatible // concurrency
263 @GwtIncompatible // concurrency
289 @GwtIncompatible // concurrency
310 @GwtIncompatible // concurrency
340 @GwtIncompatible // concurrency
353 @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/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/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/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/rust/crates/crossbeam-epoch/ |
| D | Cargo.toml.orig | 15 categories = ["concurrency", "memory-management", "no-std"]
37 # Enable the use of loom for concurrency testing.
48 # 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/kotlinx.coroutines/docs/topics/ |
| D | coroutines-basics.md | 71 ### Structured concurrency
74 **structured concurrency** which means that new coroutines can be only 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"]
|
| /external/rust/crates/rayon-core/ |
| D | Cargo.toml.orig | 14 keywords = ["parallel", "thread", "concurrency", "join", "performance"]
15 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/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CoroutineScope.kt | 25 * ### Convention for structured concurrency in <lambda>()
29 …* [job][Job] to enforce the discipline of **structured concurrency** with propagation of cancellat… in <lambda>()
35 * thus enforcing the structured concurrency. See [Job] documentation for more details. in <lambda>()
84 * By convention, should contain an instance of a [job][Job] to enforce structured concurrency. in <lambda>()
148 …* concurrency, so if it hangs or gets delayed due to a problem (e.g. due to a slow network), it wi… in plus()
|
| /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"]
37 # Enable the use of loom for concurrency testing.
|