| /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()
62 .groupby([](const item& i) { return i.concurrency; }); in run()
|
| /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/llvm-project/clang-tools-extra/clang-tidy/concurrency/ |
| D | MtUnsafeCheck.cpp | 264 template <> struct OptionEnumMapping<concurrency::MtUnsafeCheck::FunctionSet> {
266 std::pair<concurrency::MtUnsafeCheck::FunctionSet, StringRef>>
268 static constexpr std::pair<concurrency::MtUnsafeCheck::FunctionSet, in getEnumMapping()
270 Mapping[] = {{concurrency::MtUnsafeCheck::FunctionSet::Posix, "posix"}, in getEnumMapping()
271 {concurrency::MtUnsafeCheck::FunctionSet::Glibc, "glibc"}, in getEnumMapping()
272 {concurrency::MtUnsafeCheck::FunctionSet::Any, "any"}}; in getEnumMapping()
277 namespace concurrency { namespace
|
| D | ConcurrencyTidyModule.cpp | 16 namespace concurrency { namespace
21 CheckFactories.registerCheck<concurrency::MtUnsafeCheck>( in addCheckFactories()
29 static ClangTidyModuleRegistry::Add<concurrency::ConcurrencyModule>
|
| D | MtUnsafeCheck.h | 16 namespace concurrency {
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Merge.kt | 68 concurrency: Int = DEFAULT_CONCURRENCY, in <lambda>()
71 map(transform).flattenMerge(concurrency) in <lambda>()
136 public fun <T> Flow<Flow<T>>.flattenMerge(concurrency: Int = DEFAULT_CONCURRENCY): Flow<T> { in merge()
137 require(concurrency > 0) { "Expected positive concurrency level, but had $concurrency" } in merge()
138 return if (concurrency == 1) flattenConcat() else ChannelFlowMerge(this, concurrency) in merge()
|
| /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/ |
| D | coroutines-guide.md | 10 …* <a name='structured-concurrency'></a>[Structured concurrency](docs/basics.md#structured-concurre…
30 …e='structured-concurrency-with-async'></a>[Structured concurrency with async](docs/composing-suspe…
110 <!--- TOC_REF docs/shared-mutable-state-and-concurrency.md -->
111 …ate-and-concurrency'></a>[Shared mutable state and concurrency](docs/shared-mutable-state-and-conc…
112 …* <a name='the-problem'></a>[The problem](docs/shared-mutable-state-and-concurrency.md#the-problem)
113 …-no-help'></a>[Volatiles are of no help](docs/shared-mutable-state-and-concurrency.md#volatiles-ar…
114 …tures'></a>[Thread-safe data structures](docs/shared-mutable-state-and-concurrency.md#thread-safe-…
115 …d'></a>[Thread confinement fine-grained](docs/shared-mutable-state-and-concurrency.md#thread-confi…
116 …></a>[Thread confinement coarse-grained](docs/shared-mutable-state-and-concurrency.md#thread-confi…
117 …* <a name='mutual-exclusion'></a>[Mutual exclusion](docs/shared-mutable-state-and-concurrency.md#m…
[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()
77 override fun additionalToStringProps(): String = "concurrency=$concurrency" in additionalToStringProps()
|
| /external/rust/crates/crossbeam-epoch/ |
| D | Cargo.toml.orig | 16 categories = ["concurrency", "memory-management", "no-std"]
35 # Enable the use of loom for concurrency testing.
46 # Enable the use of loom for concurrency testing.
|
| /external/rust/crates/rayon/ |
| D | Cargo.toml.orig | 13 keywords = ["parallel", "thread", "concurrency", "join", "performance"]
14 categories = ["concurrency"]
|
| D | Cargo.toml | 22 keywords = ["parallel", "thread", "concurrency", "join", "performance"]
23 categories = ["concurrency"]
|
| /external/rust/crates/rayon-core/ |
| D | Cargo.toml.orig | 14 keywords = ["parallel", "thread", "concurrency", "join", "performance"]
15 categories = ["concurrency"]
|
| D | Cargo.toml | 23 keywords = ["parallel", "thread", "concurrency", "join", "performance"]
24 categories = ["concurrency"]
|
| /external/kotlinx.coroutines/benchmarks/scripts/ |
| D | generate_plots_flow_flatten_merge.py | 43 plt.xticks(data.concurrency.unique())
52 …plt.errorbar(x=res.concurrency, y=res.score*elements/1000, yerr=res.score_error*elements/1000, sol…
|
| /external/rust/crates/crossbeam-utils/ |
| D | Cargo.toml.orig | 16 categories = ["algorithms", "concurrency", "data-structures", "no-std"]
35 # Enable the use of loom for concurrency testing.
|
| /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/llvm-project/clang-tools-extra/docs/clang-tidy/checks/ |
| D | concurrency-mt-unsafe.rst | 1 .. title:: clang-tidy - concurrency-mt-unsafe
3 concurrency-mt-unsafe
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | README.md | 5 Provides abstractions over TCP/UDP I/O, file loading, polling, and concurrency
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | README.md | 5 Provides abstractions over TCP/UDP I/O, file loading, polling, and concurrency
|
| /external/curl/docs/cmdline-opts/ |
| D | parallel-max.d | 2 Help: Maximum concurrency for parallel transfers
|
| /external/skqp/experimental/canvaskit/ |
| D | karma.conf.js | 55 concurrency: Infinity, property
|
| /external/skia/experimental/wasm-skp-debugger/ |
| D | karma.conf.js | 56 concurrency: Infinity, property
|
| /external/jemalloc_new/ |
| D | jemalloc.pc.in | 8 … malloc(3) implementation that emphasizes fragmentation avoidance and scalable concurrency support.
|