| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ActorLazyTest.kt | 15 val actor = actor<String>(start = CoroutineStart.LAZY) { in <lambda>() constant
18 actor as Job // type assertion in <lambda>()
19 assertFalse(actor.isActive) in <lambda>()
20 assertFalse(actor.isCompleted) in <lambda>()
21 assertFalse(actor.isClosedForSend) in <lambda>()
24 assertFalse(actor.isActive) in <lambda>()
25 assertFalse(actor.isCompleted) in <lambda>()
26 assertFalse(actor.isClosedForSend) in <lambda>()
29 actor.start() in <lambda>()
32 assertFalse(actor.isActive) in <lambda>()
[all …]
|
| D | ActorTest.kt | 26 val actor = actor<String>(capacity = capacity) { in <lambda>() constant
29 actor as Job // type assertion in <lambda>()
30 assertTrue(actor.isActive) in <lambda>()
31 assertFalse(actor.isCompleted) in <lambda>()
32 assertFalse(actor.isClosedForSend) in <lambda>()
35 assertFalse(actor.isActive) in <lambda>()
36 assertTrue(actor.isCompleted) in <lambda>()
37 assertTrue(actor.isClosedForSend) in <lambda>()
44 val actor = actor<String>(capacity = capacity) { in <lambda>() constant
49 actor as Job // type assertion in <lambda>()
[all …]
|
| D | DoubleChannelCloseStressTest.kt | 16 … val actor = GlobalScope.actor<Int>(CoroutineName("actor"), start = CoroutineStart.LAZY) { in testDoubleCloseStress() constant
21 actor.send(1) in testDoubleCloseStress()
27 actor.close() in testDoubleCloseStress()
|
| D | ProduceConsumeJvmTest.kt | 49 val actor = actor<Int>(capacity = capacity) { in <lambda>() constant
57 actor.send(i) in <lambda>()
59 actor.close() in <lambda>()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/simulator/ |
| D | simulator.cc | 41 void Simulator::AddActor(Actor* actor) { in AddActor() argument
43 scheduled_times_.insert(std::make_pair(actor, QuicTime::Infinite())); in AddActor()
44 auto emplace_names_result = actor_names_.insert(actor->name()); in AddActor()
51 void Simulator::RemoveActor(Actor* actor) { in RemoveActor() argument
52 auto scheduled_time_it = scheduled_times_.find(actor); in RemoveActor()
53 auto actor_names_it = actor_names_.find(actor->name()); in RemoveActor()
59 Unschedule(actor); in RemoveActor()
66 void Simulator::Schedule(Actor* actor, QuicTime new_time) { in Schedule() argument
67 auto scheduled_time_it = scheduled_times_.find(actor); in Schedule()
76 Unschedule(actor); in Schedule()
[all …]
|
| D | simulator.h | 36 void Schedule(Actor* actor, QuicTime new_time);
39 void Unschedule(Actor* actor);
99 void AddActor(Actor* actor);
102 void RemoveActor(Actor* actor);
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | FailFastOnStartTest.kt | 65 actor<Int>(Dispatchers.Main) { fail() } in <lambda>()
70 val actor = actor<Int>(Dispatchers.Main, start = CoroutineStart.LAZY) { fail() } in <lambda>() constant
71 actor.send(1) in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | StatefulActorBenchmark.kt | 82 actor<Letter>(capacity = 1024) { in requestorActor()
89 return@actor in requestorActor()
102 actor<StatefulActorBenchmark.Letter>(capacity = 1024) { in computationActor()
115 is Stop -> return@actor in computationActor()
|
| D | PingPongActorBenchmark.kt | 68 actor<PingPongActorBenchmark.Letter>(capacity = capacity) { in CoroutineScope()
81 return@actor in CoroutineScope()
89 actor<PingPongActorBenchmark.Letter>(capacity = capacity) { in pongActorCoroutine()
95 return@actor in pongActorCoroutine()
|
| D | ConcurrentStatefulActorBenchmark.kt | 89 actor<Letter>(capacity = 1024) { in requestorActorUnfair()
101 return@actor in requestorActorUnfair()
115 actor<Letter>(capacity = 1024) { in requestorActorFair()
129 return@actor in requestorActorFair()
|
| D | CycledActorsBenchmark.kt | 69 private fun lastActor(stopChannel: Channel<Unit>) = actor<Letter>(capacity = 1024) { in <lambda>()
84 return@actor in <lambda>()
91 …private fun createActor(nextActor: SendChannel<Letter>, stopChannel: Channel<Unit>) = actor<Letter… in <lambda>()
101 return@actor in <lambda>()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_mpsc_weak.rs | 138 let actor = MyActor::new(receiver, sender.clone().downgrade()); in actor_weak_sender() localVariable
140 (Self { sender }, actor) in actor_weak_sender()
155 let (handle, mut actor) = MyActorHandle::new(); in actor_weak_sender()
157 let actor_handle = tokio::spawn(async move { actor.run().await }); in actor_weak_sender()
399 let actor = MyActor::new(receiver, sender.clone().downgrade()); in actor_weak_unbounded_sender() localVariable
401 (Self { sender }, actor) in actor_weak_unbounded_sender()
416 let (handle, mut actor) = MyActorHandle::new(); in actor_weak_unbounded_sender()
418 let actor_handle = tokio::spawn(async move { actor.run().await }); in actor_weak_unbounded_sender()
|
| /external/jackson-databind/src/test/java/com/fasterxml/jackson/databind/deser/filter/ |
| D | ProblemHandlerLocation1440Test.java | 80 public ActivityEntity actor; field in ProblemHandlerLocation1440Test.Activity
86 …public Activity(@JsonProperty("actor") final ActivityEntity actor, @JsonProperty("object") final A… in Activity() argument
87 this.actor = actor; in Activity()
|
| /external/perfetto/src/traced/probes/ftrace/test/data/android_raven_AOSP.MASTER_5.10.43/events/iomap/iomap_apply/ |
| D | format | 15 field:void * actor; offset:56; size:8; signed:0;
18 …actor %ps", ((unsigned int) ((REC->dev) >> 20)), ((unsigned int) ((REC->dev) & ((1U << 20) - 1))),…
|
| /external/kotlinx.coroutines/ui/ |
| D | coroutines-guide-ui.md | 219 <!--- INCLUDE .*/example-ui-actor-([0-9]+).kt -->
234 > You can get the full code [here](kotlinx-coroutines-javafx/test/guide/example-ui-actor-01.kt).
260 or otherwise ignore a cancellation signal. A better solution is to use an [actor] for tasks that sh…
265 // launch one actor to handle all events on this node
266 val eventActor = GlobalScope.actor<MouseEvent>(Dispatchers.Main) {
269 // install a listener to offer events to this actor
276 > You can get the full code [here](kotlinx-coroutines-javafx/test/guide/example-ui-actor-02.kt).
278 The key idea that underlies an integration of an actor coroutine and a regular event handler is tha…
279 …rySend] function on [SendChannel] that does not wait. It sends an element to the actor immediately,
283 animation is running. This happens because the actor is busy with an animation and does not receive…
[all …]
|
| /external/antlr/runtime/ObjC/Framework/ |
| D | TreeRewriter.h | 36 id actor; variable
45 @property (retain) id actor;
|
| D | TreeRewriter.m | 48 actor = anObject;
56 if ( [actor respondsToSelector:ruleSEL] )
57 return [actor performSelector:ruleSEL];
63 @synthesize actor;
|
| D | TreeWizard.h | 49 id actor; variable
60 @property (retain) id actor;
|
| D | TreeWizard.m | 48 actor = anActor;
49 if ( actor ) [actor retain];
63 if ( actor ) [actor release];
74 … if ( [(TreeWizard *)actor _parse:t Pattern:object1/* tpattern */ Map:object2 /* labels */] ) {
79 if ( [(TreeWizard *)actor _parse:t Pattern:object1/* tpattern */ Map:nil] ) {
95 @synthesize actor;
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_semaphore_batch.rs | 23 async fn actor(shared: Arc<Shared>) { in basic_usage() function
43 block_on(actor(shared)); in basic_usage()
47 block_on(actor(shared)); in basic_usage()
|
| /external/cronet/net/url_request/ |
| D | url_request_throttler_simulation_unittest.cc | 88 void AddActor(Actor* actor) { in AddActor() argument
89 actors_.push_back(actor); in AddActor()
101 for (auto* actor : actors_) { in RunSimulation() local
102 actor->AdvanceTime(now); in RunSimulation()
105 for (auto* actor : actors_) { in RunSimulation() local
106 actor->PerformAction(); in RunSimulation()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/ |
| D | README.md | 12 | [actor][kotlinx.coroutines.channels.actor] | [SendChannel][kotlinx.coroutines.channels.SendCh…
135 ….coroutines.channels.actor]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-core…
137 …/api/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.channels/-actor-scope/index.html
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-sync-07.kt | 33 fun CoroutineScope.counterActor() = actor<CounterMsg> { in <lambda>()
|
| /external/python/cpython2/Doc/tools/ |
| D | susp-ignored.csv | 138 library/xml.etree.elementtree,,:actor,"for actor in root.findall('real_person:actor', ns):"
139 library/xml.etree.elementtree,,:name,"name = actor.find('real_person:name', ns)"
140 library/xml.etree.elementtree,,:character,"for char in actor.findall('role:character', ns):"
|
| /external/python/cpython2/Doc/library/ |
| D | xml.etree.elementtree.rst | 288 <actor>
292 </actor>
293 <actor>
298 </actor>
306 for actor in root.findall('{http://people.example.com}actor'):
307 name = actor.find('{http://people.example.com}name')
309 for char in actor.findall('{http://characters.example.com}character'):
319 for actor in root.findall('real_person:actor', ns):
320 name = actor.find('real_person:name', ns)
322 for char in actor.findall('role:character', ns):
|