| /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/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/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/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/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/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/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/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/cronet/base/task/thread_pool/ |
| D | job_task_source.h | 33 // Derived classes control the intended concurrency with GetMaxConcurrency().
47 // Notifies this task source that max concurrency increased. Returns false iff
99 // is decremented or capacity is created by a max concurrency increase.
146 // decremented or capacity is created by increasing "max concurrency".
152 // concurrency". Resets the bit so that this won't return true until
164 // `WillRunTask()` determined that max concurrency is reached. Returns true
190 // equal to max concurrency (may happen when "max concurrency" increases or
210 // created by increasing "max concurrency" or decrementing the worker count.
|
| /external/crosvm/cros_async/src/sys/windows/ |
| 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 …]
|
| 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()
|
| /external/cronet/third_party/libc++/src/docs/Helpers/ |
| D | Styles.rst | 25 .concurrency { background-color: #909090; white-space:nowrap; }
48 .. role:: concurrency
56 .. |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/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/crates/sync_wrapper/ |
| D | Cargo.toml.orig | 6 description = "A tool for enlisting the compiler's help in proving the absence of concurrency"
12 keywords = ["concurrency"]
13 categories = ["concurrency"]
|
| 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/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/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/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_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.
|
| /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.
48 # Enable the use of loom for concurrency testing.
|