Home
last modified time | relevance | path

Searched refs:executors (Results 1 – 25 of 1603) sorted by relevance

12345678910>>...65

/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/deploy/
H A DStandaloneDynamicAllocationSuite.scala101 assert(apps.head.executors.size === 0)
106 assert(apps.head.executors.size === 1)
111 assert(apps.head.executors.size === 2)
116 assert(apps.head.executors.size === 2)
121 assert(apps.head.executors.size === 1)
368 val executors = getExecutorIds(sc) constant
369 assert(executors.size === 2)
391 val executors = getExecutorIds(sc) constant
393 assert(executors.size === 2)
432 val executors = getExecutorIds(sc) constant
[all …]
/dports/emulators/mess/mame-mame0226/3rdparty/asio/src/examples/cpp14/
H A DMakefile.am19 executors/actor \
20 executors/async_1 \
21 executors/async_2 \
22 executors/bank_account_1 \
23 executors/bank_account_2 \
24 executors/fork_join \
25 executors/pipeline \
26 executors/priority_scheduler \
37 executors_actor_SOURCES = executors/actor.cpp
38 executors_async_1_SOURCES = executors/async_1.cpp
[all …]
/dports/emulators/mame/mame-mame0226/3rdparty/asio/src/examples/cpp14/
H A DMakefile.am19 executors/actor \
20 executors/async_1 \
21 executors/async_2 \
22 executors/bank_account_1 \
23 executors/bank_account_2 \
24 executors/fork_join \
25 executors/pipeline \
26 executors/priority_scheduler \
37 executors_actor_SOURCES = executors/actor.cpp
38 executors_async_1_SOURCES = executors/async_1.cpp
[all …]
/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/modules/asio-standalone/asio/src/examples/cpp14/
H A DMakefile.am19 executors/actor \
20 executors/async_1 \
21 executors/async_2 \
22 executors/bank_account_1 \
23 executors/bank_account_2 \
24 executors/fork_join \
25 executors/pipeline \
26 executors/priority_scheduler \
37 executors_actor_SOURCES = executors/actor.cpp
38 executors_async_1_SOURCES = executors/async_1.cpp
[all …]
/dports/multimedia/obs-websocket/obs-websocket-4.8.0/deps/asio/asio/src/examples/cpp14/
H A DMakefile.am19 executors/actor \
20 executors/async_1 \
21 executors/async_2 \
22 executors/bank_account_1 \
23 executors/bank_account_2 \
24 executors/fork_join \
25 executors/pipeline \
26 executors/priority_scheduler \
37 executors_actor_SOURCES = executors/actor.cpp
38 executors_async_1_SOURCES = executors/async_1.cpp
[all …]
/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/scheduler/
H A DReceiverSchedulingPolicySuite.scala40 0, Some("host1"), receiverTrackingInfoMap, executors)
50 1, None, receiverTrackingInfoMap, executors)
51 assert(scheduledLocations.toSet === executors.tail.toSet)
55 val executors = Seq( constant
76 4, None, receiverTrackingInfoMap, executors)
88 val executors = (0 until 3).map(executorId => constant
104 val executors = (0 until 6).map(executorId => constant
122 val executors = (0 until 3).map(executorId => constant
130 assert(executors.size == 1)
131 executors.foreach { l =>
[all …]
/dports/www/restbed/restbed-4.8/dependency/asio/asio/src/examples/cpp14/
H A DMakefile.am19 executors/actor \
20 executors/async_1 \
21 executors/async_2 \
22 executors/bank_account_1 \
23 executors/bank_account_2 \
24 executors/fork_join \
25 executors/pipeline \
26 executors/priority_scheduler \
45 executors_actor_SOURCES = executors/actor.cpp
46 executors_async_1_SOURCES = executors/async_1.cpp
[all …]
/dports/net/asio/asio-1.16.0/src/examples/cpp14/
H A DMakefile.am19 executors/actor \
20 executors/async_1 \
21 executors/async_2 \
22 executors/bank_account_1 \
23 executors/bank_account_2 \
24 executors/fork_join \
25 executors/pipeline \
26 executors/priority_scheduler \
45 executors_actor_SOURCES = executors/actor.cpp
46 executors_async_1_SOURCES = executors/async_1.cpp
[all …]
H A DMakefile.in99 executors/actor$(EXEEXT) executors/async_1$(EXEEXT) \
100 executors/async_2$(EXEEXT) executors/bank_account_1$(EXEEXT) \
101 executors/bank_account_2$(EXEEXT) executors/fork_join$(EXEEXT) \
288 executors/$(DEPDIR)/actor.Po executors/$(DEPDIR)/async_1.Po \
622 executors/actor.$(OBJEXT): executors/$(am__dirstamp) \
628 executors/async_1.$(OBJEXT): executors/$(am__dirstamp) \
634 executors/async_2.$(OBJEXT): executors/$(am__dirstamp) \
640 executors/bank_account_1.$(OBJEXT): executors/$(am__dirstamp) \
646 executors/bank_account_2.$(OBJEXT): executors/$(am__dirstamp) \
652 executors/fork_join.$(OBJEXT): executors/$(am__dirstamp) \
[all …]
/dports/databases/pymongo/pymongo-3.12.0/test/
H A Dtest_monitor.py38 executors = []
40 executors.append(server._monitor._executor)
41 executors.append(server._monitor._rtt_monitor._executor)
42 executors.append(client._kill_cursors_executor)
44 return [e for e in executors if e is not None]
57 executors = get_executors(client)
58 self.assertEqual(len(executors), 4)
64 del executors
74 executors = get_executors(client)
75 self.assertEqual(len(executors), 4)
[all …]
/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/modules/asio-standalone/asio/src/examples/cpp11/
H A DMakefile.am23 executors/actor \
24 executors/bank_account_1 \
25 executors/bank_account_2 \
26 executors/fork_join \
27 executors/pipeline \
28 executors/priority_scheduler \
54 executors_actor_SOURCES = executors/actor.cpp
55 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp
56 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp
57 executors_fork_join_SOURCES = executors/fork_join.cpp
[all …]
/dports/emulators/mess/mame-mame0226/3rdparty/asio/src/examples/cpp11/
H A DMakefile.am23 executors/actor \
24 executors/bank_account_1 \
25 executors/bank_account_2 \
26 executors/fork_join \
27 executors/pipeline \
28 executors/priority_scheduler \
54 executors_actor_SOURCES = executors/actor.cpp
55 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp
56 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp
57 executors_fork_join_SOURCES = executors/fork_join.cpp
[all …]
/dports/emulators/mame/mame-mame0226/3rdparty/asio/src/examples/cpp11/
H A DMakefile.am23 executors/actor \
24 executors/bank_account_1 \
25 executors/bank_account_2 \
26 executors/fork_join \
27 executors/pipeline \
28 executors/priority_scheduler \
54 executors_actor_SOURCES = executors/actor.cpp
55 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp
56 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp
57 executors_fork_join_SOURCES = executors/fork_join.cpp
[all …]
/dports/devel/grpc130/grpc-1.30.2/src/core/lib/iomgr/
H A Dexecutor.cc61 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
66 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
71 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
76 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
395 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
397 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
400 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll()
401 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll()
437 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll()
438 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll()
[all …]
/dports/devel/grpc/grpc-1.42.0/src/core/lib/iomgr/
H A Dexecutor.cc60 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
65 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
70 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
75 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
381 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
383 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
386 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll()
387 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll()
423 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll()
424 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll()
[all …]
/dports/devel/grpc134/grpc-1.34.1/src/core/lib/iomgr/
H A Dexecutor.cc61 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
66 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
71 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
76 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
395 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
397 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
400 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll()
401 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll()
437 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll()
438 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll()
[all …]
/dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/iomgr/
H A Dexecutor.cc60 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
65 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
70 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
75 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
381 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
383 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
386 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll()
387 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll()
423 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll()
424 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll()
[all …]
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/lib/iomgr/
H A Dexecutor.cc60 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
65 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
70 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
75 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
378 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
380 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
383 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll()
384 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll()
420 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll()
421 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll()
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/
H A DRamDiskAsyncLazyPersistService.java55 private Map<File, ThreadPoolExecutor> executors field in RamDiskAsyncLazyPersistService
88 executors.put(volume, executor); in addExecutorForVolume()
96 if (executors == null) { in addVolume()
99 ThreadPoolExecutor executor = executors.get(volume); in addVolume()
111 if (executors == null) { in removeVolume()
120 executors.remove(volume); in removeVolume()
131 if (executors == null) { in queryVolume()
142 if (executors == null) { in execute()
145 ThreadPoolExecutor executor = executors.get(root); in execute()
159 if (executors == null) { in shutdown()
[all …]
H A DFsDatasetAsyncDiskService.java72 private Map<File, ThreadPoolExecutor> executors field in FsDatasetAsyncDiskService
116 executors.put(volume, executor); in addExecutorForVolume()
124 if (executors == null) { in addVolume()
127 ThreadPoolExecutor executor = executors.get(volume); in addVolume()
139 if (executors == null) { in removeVolume()
142 ThreadPoolExecutor executor = executors.get(volume); in removeVolume()
148 executors.remove(volume); in removeVolume()
164 if (executors == null) { in execute()
167 ThreadPoolExecutor executor = executors.get(root); in execute()
181 if (executors == null) { in shutdown()
[all …]
/dports/multimedia/obs-websocket/obs-websocket-4.8.0/deps/asio/asio/src/examples/cpp11/
H A DMakefile.am23 executors/actor \
24 executors/bank_account_1 \
25 executors/bank_account_2 \
26 executors/fork_join \
27 executors/pipeline \
28 executors/priority_scheduler \
68 executors_actor_SOURCES = executors/actor.cpp
69 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp
70 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp
71 executors_fork_join_SOURCES = executors/fork_join.cpp
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/iomgr/
H A Dexecutor.cc58 Executor* executors[static_cast<size_t>(ExecutorType::NUM_EXECUTORS)]; variable
61 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
66 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
71 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
76 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
410 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll()
412 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll()
415 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll()
457 executors[static_cast<size_t>(ExecutorType::DEFAULT)]); in ShutdownAll()
459 executors[static_cast<size_t>(ExecutorType::RESOLVER)]); in ShutdownAll()
[all …]
/dports/www/restbed/restbed-4.8/dependency/asio/asio/src/examples/cpp11/
H A DMakefile.am23 executors/actor \
24 executors/bank_account_1 \
25 executors/bank_account_2 \
26 executors/fork_join \
27 executors/pipeline \
28 executors/priority_scheduler \
91 executors_actor_SOURCES = executors/actor.cpp
92 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp
93 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp
94 executors_fork_join_SOURCES = executors/fork_join.cpp
[all …]
/dports/net/asio/asio-1.16.0/src/examples/cpp11/
H A DMakefile.am23 executors/actor \
24 executors/bank_account_1 \
25 executors/bank_account_2 \
26 executors/fork_join \
27 executors/pipeline \
28 executors/priority_scheduler \
90 executors_actor_SOURCES = executors/actor.cpp
91 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp
92 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp
93 executors_fork_join_SOURCES = executors/fork_join.cpp
[all …]
/dports/devel/hpx/hpx-1.2.1/hpx/parallel/executors/
H A Dservice_executors.hpp27 using service_executor = threads::executors::service_executor;
36 using io_pool_executor = threads::executors::io_pool_executor;
45 using parcel_pool_executor = threads::executors::parcel_pool_executor;
54 using timer_pool_executor = threads::executors::timer_pool_executor;
63 using main_pool_executor = threads::executors::main_pool_executor;

12345678910>>...65