| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Merge.kt | 22 * Default concurrency limit that is used by [flattenMerge] and [flatMapMerge] operators. in <lambda>()
49 … operator calls [transform] *sequentially* and then merges the resulting flows with a [concurrency] in <lambda>()
51 * It is a shortcut for `map(transform).flattenMerge(concurrency)`. in <lambda>()
62 …* @param concurrency controls the number of in-flight flows, at most [concurrency] flows are colle… in <lambda>()
67 concurrency: Int = DEFAULT_CONCURRENCY, in <lambda>()
70 map(transform).flattenMerge(concurrency) in <lambda>()
117 * Flattens the given flow of flows into a single flow with a [concurrency] limit on the number of in merge()
120 * If [concurrency] is more than 1, then inner flows are collected by this operator *concurrently*. in merge()
121 * With `concurrency == 1` this operator is identical to [flattenConcat]. in merge()
128 * 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 | 24 private var concurrency: Int = 0 in <lambda>() variable in benchmarks.flow.FlowFlattenMergeBenchmark
30 val n = flowsNumberStrategy.get(concurrency) in <lambda>()
45 flow.flattenMerge(concurrency = concurrency).collect() in <lambda>()
49 enum class FlowsNumberStrategy(val get: (concurrency: Int) -> Int) {
50 `10xConcurrency flows`({ concurrency -> concurrency * 10 }), in concurrency() method
|
| /external/sdv/vsomeip/third_party/boost/asio/doc/overview/ |
| D | concurrency_hint.qbk | 8 [section:concurrency_hint Concurrency Hints]
11 allows programs to specify a concurrency hint. This is a suggestion to the
19 following special concurrency hint values:
39 This special concurrency hint disables locking in both the scheduler and
55 This special concurrency hint disables locking in the reactor I/O. This
73 The concurrency hint used by default-constructed `io_context` objects can be
79 on the compiler command line means that a concurrency hint of `1` is used for
81 concurrency hint used by `io_context` objects constructed with `1` can be
|
| /external/sdv/vsomeip/third_party/boost/asio/include/boost/asio/detail/ |
| D | concurrency_hint.hpp | 21 // The concurrency hint ID and mask are used to identify when a "well-known"
22 // concurrency hint value has been passed to the io_context.
36 // Helper macro to determine if we have a special concurrency hint.
49 // This special concurrency hint disables locking in both the scheduler and
63 // This special concurrency hint disables locking in the reactor I/O. This hint
74 // The special concurrency hint provides full thread safety.
82 // default concurrency hint, used by the zero-argument io_context constructor.
88 // concurrency hint, used by the one-argument io_context constructor when
|
| /external/pytorch/.github/scripts/ |
| D | ensure_actions_will_cancel.py | 41 actual = data.get("concurrency", {})
45 f"'concurrency' incorrect or not found in '{filename.relative_to(REPO_ROOT)}'",
49 …f"concurrency group should start with {EXPECTED_GROUP_PREFIX} but found {actual.get('group', None)…
55 f"'concurrency' incorrect or not found in '{filename.relative_to(REPO_ROOT)}'",
59 … f"concurrency group should start with {EXPECTED_GROUP} but found {actual.get('group', None)}",
65 f"'concurrency' incorrect or not found in '{filename.relative_to(REPO_ROOT)}'",
69 …f"concurrency cancel-in-progress should be True but found {actual.get('cancel-in-progress', None)}…
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Uninterruptibles.java | 57 @GwtIncompatible // concurrency
83 @GwtIncompatible // concurrency
93 @GwtIncompatible // concurrency
124 @GwtIncompatible // concurrency
136 @GwtIncompatible // concurrency
161 @GwtIncompatible // concurrency
187 @GwtIncompatible // concurrency
197 @GwtIncompatible // concurrency
335 @GwtIncompatible // concurrency
362 @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/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/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | Merge.kt | 39 private val concurrency: Int, constant in ChannelFlowMerge
45 ChannelFlowMerge(flow, concurrency, context, capacity, onBufferOverflow) in create()
52 val semaphore = Semaphore(concurrency) in collectTo()
67 semaphore.release() // Release concurrency permit in collectTo()
73 override fun additionalToStringProps(): String = "concurrency=$concurrency" in additionalToStringProps()
|
| /external/googleapis/google/datastore/admin/v1/ |
| D | migration.proto | 39 // Concurrency modes for transactions in Cloud Firestore.
44 // Pessimistic concurrency.
47 // Optimistic concurrency.
50 // Optimistic concurrency with entity groups.
56 // The concurrency mode this database will use when it reaches the
63 // Ths concurrency mode for this database.
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | Uninterruptibles.java | 55 @GwtIncompatible // concurrency
79 @GwtIncompatible // concurrency
110 @GwtIncompatible // concurrency
135 @GwtIncompatible // concurrency
159 @GwtIncompatible // concurrency
269 @GwtIncompatible // concurrency
296 @GwtIncompatible // concurrency
318 @GwtIncompatible // concurrency
349 @GwtIncompatible // concurrency
363 @GwtIncompatible // concurrency
[all …]
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | executor.rs | 10 Overlapped { concurrency: Option<u32> },
20 ExecutorKindSys::Overlapped { concurrency: None } => "overlapped".to_string(), in serialize()
22 concurrency: Some(n), in serialize()
23 } => format!("overlapped,concurrency={}", n), in serialize()
|
| D | io_completion_port.rs | 79 concurrency: u32, field
223 pub fn new(concurrency: u32) -> Result<Self> { in new()
227 let port = create_iocp(None, None, 0, concurrency)?.unwrap(); in new()
229 if concurrency > 1 { in new()
230 info!("creating iocp with concurrency: {}", concurrency); in new()
231 for i in 0..concurrency { in new()
249 concurrency, in new()
254 self.concurrency > 1 in threaded()
264 self.concurrency, in register_descriptor()
430 concurrency: u32, in create_iocp()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | FlatMapStressTest.kt | 86 val concurrency = AtomicLong() in <lambda>() constant
87 val result = (1L..iterations).asFlow().flatMapMerge(concurrency = maxConcurrency) { value -> in <lambda>()
89 val current = concurrency.incrementAndGet() in <lambda>()
92 concurrency.decrementAndGet() in <lambda>()
96 assertEquals(0, concurrency.get()) in <lambda>()
|
| /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/aws-sdk-java-v2/http-client-spi/src/main/java/software/amazon/awssdk/http/ |
| D | HttpMetric.java | 45 …* individual HTTP client instance, and does not include concurrency that may be available in other…
62 …* individual HTTP client instance, and does not include concurrency that may be available in other…
78 …* individual HTTP client instance, and does not include concurrency that may be available in other…
85 … * The number of requests that are awaiting concurrency to be made available from the HTTP client.
94 …* individual HTTP client instance, and does not include concurrency that may be available in other…
115 …* <li>Awaiting a concurrency permit, as restricted by the client's max concurrency configurati…
|
| /external/rust/android-crates-io/crates/tower/ |
| D | .android-checksum.json | 1 …concurrency/future.rs":"69e93ae169d953a2456feeabefd937ba8885a905e04dfca938605d38eef4c785","src/lim…
|
| D | .cargo-checksum.json | 1 …concurrency/future.rs":"0c3be7829f7cf0ea57c6277193754e4f8b869f5a4e3e46b1a5c2ffe41ddb812f","src/lim…
|
| /external/rust/android-crates-io/crates/sync_wrapper/ |
| D | Cargo.toml | 17 description = "A tool for enlisting the compiler's help in proving the absence of concurrency"
21 keywords = ["concurrency"]
22 categories = ["concurrency"]
|
| /external/crosvm/devices/src/virtio/block/sys/ |
| D | windows.rs | 40 if let ExecutorKind::SysVariants(ExecutorKindSys::Overlapped { concurrency }) = &mut kind { in create_executor()
41 if concurrency.is_none() { in create_executor()
42 *concurrency = Some(self.io_concurrency); in create_executor()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | DefaultDispatchersTest.kt | 63 val concurrency = AtomicInteger() in <lambda>() constant
66 val c = concurrency.incrementAndGet() in <lambda>()
68 concurrency.decrementAndGet() in <lambda>()
|
| /external/aws-sdk-java-v2/test/stability-tests/src/it/java/software/amazon/awssdk/stability/tests/s3/ |
| D | S3BaseStabilityTest.java | 49 protected static final int CONCURRENCY = 100; field in S3BaseStabilityTest
68 .maxConnections(CONCURRENCY))
79 … // use the passed in known thread count for testClient, plus CONCURRENCY for the sync executor, in S3BaseStabilityTest()
81 this.allowedPeakThreads = testClientThreadsUsed + CONCURRENCY + ALLOWED_THREAD_OVERHEAD; in S3BaseStabilityTest()
176 .requestCountPerRun(CONCURRENCY) in putObject()
194 .requestCountPerRun(CONCURRENCY) in getObject()
|
| /external/rust/android-crates-io/crates/tower/examples/ |
| D | tower-balance.rs | 17 use tower::limit::concurrency::ConcurrencyLimit;
23 const CONCURRENCY: usize = 500; constant
25 static ENDPOINT_CAPACITY: usize = CONCURRENCY;
50 println!("CONCURRENCY={}", CONCURRENCY); in main()
155 let service = ConcurrencyLimit::new(lb, CONCURRENCY); in run()
|
| /external/grpc-grpc/src/ruby/end2end/ |
| D | grpc_class_init_test.rb | 33 # TODO(b/266212253): re-enable the "concurrency" mode
59 # concurrency stress test type is expected to exit with a
61 if client_exit_code != 0 && stress_test_type != 'concurrency'
|
| /external/googleapis/google/firestore/admin/v1/ |
| D | database.proto | 57 // The type of concurrency control mode for transactions.
62 // Use optimistic concurrency control by default. This mode is available
66 // Use pessimistic concurrency control by default. This mode is available
72 // Use optimistic concurrency control with entity groups by default.
158 // The concurrency control mode to use for this database.
|