| /dports/biology/gatk/gatk-4.2.0.0/src/test/java/org/broadinstitute/hellbender/utils/R/ |
| H A D | RScriptExecutorUnitTest.java | 34 RScriptExecutor executor = new RScriptExecutor(); in testExistingScript() local
44 RScriptExecutor executor = new RScriptExecutor(); in testNonExistentScriptException() local
52 RScriptExecutor executor = new RScriptExecutor(); in testNonExistentScriptNoException() local
62 RScriptExecutor executor = new RScriptExecutor(); in testLibrary() local
75 RScriptExecutor executor = new RScriptExecutor(); in testLibraryMissing() local
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/util/concurrent/forkjoin/ |
| H A D | AsyncShutdownNow.java | 75 private void scheduleShutdownNow(ExecutorService executor, int delayInSeconds) { in scheduleShutdownNow()
97 public void testFutureGet(ExecutorService executor) throws Exception { in testFutureGet()
118 public void testTimedFutureGet(ExecutorService executor) throws Exception { in testTimedFutureGet()
139 public void testInvokeAll(ExecutorService executor) throws Exception { in testInvokeAll()
163 public void testInvokeAny(ExecutorService executor) throws Exception { in testInvokeAny()
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/mcpp2-compare/gen-py3/module/ |
| H A D | services_wrapper.h | 24 folly::Executor *executor; variable
35 folly::Executor *executor; variable
71 folly::Executor *executor; variable
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/basic-stack-arguments/gen-py3/module/ |
| H A D | services_wrapper.h | 22 folly::Executor *executor; variable
47 folly::Executor *executor; variable
72 folly::Executor *executor; variable
|
| /dports/devel/folly/folly-2021.12.27.00/folly/executors/ |
| H A D | GlobalExecutor.cpp | 91 if (auto executor = executor_.lock()) { in get() local
98 void set(std::weak_ptr<ExecutorBase> executor) { in set()
164 auto executor = singleton.get(); in getUnsafeMutableGlobalCPUExecutor() local
182 void setUnsafeMutableGlobalCPUExecutor(std::weak_ptr<Executor> executor) { in setUnsafeMutableGlobalCPUExecutor()
187 void setCPUExecutor(std::weak_ptr<Executor> executor) { in setCPUExecutor()
193 auto executor = singleton.get(); in getUnsafeMutableGlobalIOExecutor() local
202 void setUnsafeMutableGlobalIOExecutor(std::weak_ptr<IOExecutor> executor) { in setUnsafeMutableGlobalIOExecutor()
207 void setIOExecutor(std::weak_ptr<IOExecutor> executor) { in setIOExecutor()
212 auto executor = getUnsafeMutableGlobalIOExecutor(); in getUnsafeMutableGlobalEventBase() local
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Activities/System/Activities/Runtime/ |
| H A D | ExecuteSynchronousExpressionWorkItem.cs | 114 public override bool Execute(ActivityExecutor executor, BookmarkManager bookmarkManager) in Execute()
179 protected override void ReleaseToPool(ActivityExecutor executor) in ReleaseToPool()
191 private void EvaluateNextArgument(ActivityExecutor executor) in EvaluateNextArgument()
213 private void TrackClosed(ActivityExecutor executor, ref ActivityInfo activityInfo) in TrackClosed()
221 private void TrackExecuting(ActivityExecutor executor, ref ActivityInfo activityInfo) in TrackExecuting()
229 private void TrackFaulted(ActivityExecutor executor, ref ActivityInfo activityInfo) in TrackFaulted()
237 …private void TrackState(ActivityExecutor executor, ActivityInstanceState state, ref ActivityInfo a… in TrackState()
|
| H A D | WorkItem.cs | 130 public void Dispose(ActivityExecutor executor) in Dispose()
158 protected virtual void ReleaseToPool(ActivityExecutor executor) in ReleaseToPool()
222 public void Release(ActivityExecutor executor) in Release()
262 public abstract bool Execute(ActivityExecutor executor, BookmarkManager bookmarkManager); in Execute()
264 public abstract void PostProcess(ActivityExecutor executor); in PostProcess()
266 public bool FlushBookmarkScopeKeys(ActivityExecutor executor) in FlushBookmarkScopeKeys()
315 public bool FlushTracking(ActivityExecutor executor) in FlushTracking()
355 public CallbackData(ActivityExecutor executor, WorkItem workItem) in CallbackData()
|
| /dports/devel/py-aiofiles/aiofiles-0.8.0/src/aiofiles/threadpool/ |
| H A D | __init__.py | 34 executor=None argument
64 executor=None argument
86 def wrap(file, *, loop=None, executor=None): argument
91 def _(file, *, loop=None, executor=None): argument
96 def _(file, *, loop=None, executor=None): argument
102 def _(file, *, loop=None, executor=None): argument
107 def _(file, *, loop=None, executor=None): argument
|
| /dports/biology/gatk/gatk-4.2.0.0/src/test/java/org/broadinstitute/hellbender/utils/python/ |
| H A D | PythonScriptExecutorUnitTest.java | 40 final PythonScriptExecutor executor = new PythonScriptExecutor(true); in testExecuteAsModule() local
50 final PythonScriptExecutor executor = new PythonScriptExecutor(true); in testExecuteAsScript() local
60 final PythonScriptExecutor executor = new PythonScriptExecutor(true); in testExecuteAsScriptAndGetProcessOutput() local
70 final PythonScriptExecutor executor = new PythonScriptExecutor(true); in testExecuteAsScriptAndGetProcessOutputWithFailureCode() local
124 final PythonScriptExecutor executor = new PythonScriptExecutor(true); in testExecuteAsScriptWithScriptArguments() local
135 final PythonScriptExecutor executor = new PythonScriptExecutor(true); in testNonExistentScriptException() local
144 final PythonScriptExecutor executor = new PythonScriptExecutor(true); in testNonExistentScriptNoException() local
|
| /dports/devel/py-aiofiles/aiofiles-0.8.0/src/aiofiles/tempfile/ |
| H A D | __init__.py | 39 executor=None, argument
68 executor=None, argument
97 executor=None, argument
139 executor=None, argument
194 executor=None, argument
219 suffix=None, prefix=None, dir=None, loop=None, executor=None argument
240 def wrap(base_io_obj, file, *, loop=None, executor=None): argument
246 def _(base_io_obj, file, *, loop=None, executor=None): argument
251 def _(base_io_obj, file, *, loop=None, executor=None): argument
257 def _(base_io_obj, file, *, loop=None, executor=None): argument
[all …]
|
| /dports/databases/py-litecli/litecli-1.6.0/tests/ |
| H A D | test_main.py | 21 def test_execute_arg(executor): argument
43 def test_execute_arg_with_table(executor): argument
57 def test_execute_arg_with_csv(executor): argument
71 def test_batch_mode(executor): argument
85 def test_batch_mode_table(executor): argument
113 def test_batch_mode_csv(executor): argument
244 def test_import_command(executor): argument
|
| /dports/net-p2p/c-lightning/lightning-0.10.2/tests/ |
| H A D | test_closing.py | 171 def test_closing_torture(node_factory, executor, bitcoind): argument
1758 def test_onchain_dust_out(node_factory, bitcoind, executor): argument
1830 def test_onchain_timeout(node_factory, bitcoind, executor): argument
2193 def test_onchain_feechange(node_factory, bitcoind, executor): argument
2274 def test_onchain_all_dust(node_factory, bitcoind, executor): argument
2708 def test_permfail_htlc_in(node_factory, bitcoind, executor): argument
2754 def test_permfail_htlc_out(node_factory, bitcoind, executor): argument
3122 def test_closing_higherfee(node_factory, bitcoind, executor): argument
3158 def test_htlc_rexmit_while_closing(node_factory, executor): argument
3203 def test_you_forgot_closed_channel(node_factory, executor): argument
[all …]
|
| /dports/databases/py-litecli/litecli-1.6.0/litecli/ |
| H A D | completion_refresher.py | 17 def refresh(self, executor, callbacks, completer_options=None): argument
107 def refresh_databases(completer, executor): argument
112 def refresh_schemata(completer, executor): argument
119 def refresh_tables(completer, executor): argument
125 def refresh_functions(completer, executor): argument
130 def refresh_special(completer, executor): argument
|
| /dports/java/springframework31/spring-framework-3.1.4.RELEASE/projects/org.springframework.context/src/main/java/org/springframework/scheduling/concurrent/ |
| H A D | ThreadPoolTaskScheduler.java | 116 Executor executor = getScheduledExecutor(); in execute() local
130 ExecutorService executor = getScheduledExecutor(); in submit() local
140 ExecutorService executor = getScheduledExecutor(); in submit() local
160 ScheduledExecutorService executor = getScheduledExecutor(); in schedule() local
172 ScheduledExecutorService executor = getScheduledExecutor(); in schedule() local
183 ScheduledExecutorService executor = getScheduledExecutor(); in scheduleAtFixedRate() local
194 ScheduledExecutorService executor = getScheduledExecutor(); in scheduleAtFixedRate() local
204 ScheduledExecutorService executor = getScheduledExecutor(); in scheduleWithFixedDelay() local
215 ScheduledExecutorService executor = getScheduledExecutor(); in scheduleWithFixedDelay() local
|
| /dports/devel/hpx/hpx-1.2.1/tests/unit/parallel/executors/ |
| H A D | parallel_executor.cpp | 27 typedef hpx::parallel::execution::parallel_executor executor; in test_sync() typedef
36 typedef hpx::parallel::execution::parallel_executor executor; in test_async() typedef
57 typedef hpx::parallel::execution::parallel_executor executor; in test_then() typedef
76 typedef hpx::parallel::execution::parallel_executor executor; in test_bulk_sync() typedef
96 typedef hpx::parallel::execution::parallel_executor executor; in test_bulk_async() typedef
129 typedef hpx::parallel::execution::parallel_executor executor; in test_bulk_then() typedef
154 using executor = hpx::parallel::execution::parallel_executor; in static_check_executor() typedef
|
| H A D | parallel_fork_executor.cpp | 27 typedef hpx::parallel::execution::parallel_executor executor; in test_sync() typedef
36 typedef hpx::parallel::execution::parallel_executor executor; in test_async() typedef
57 typedef hpx::parallel::execution::parallel_executor executor; in test_then() typedef
76 typedef hpx::parallel::execution::parallel_executor executor; in test_bulk_sync() typedef
95 typedef hpx::parallel::execution::parallel_executor executor; in test_bulk_async() typedef
128 typedef hpx::parallel::execution::parallel_executor executor; in test_bulk_then() typedef
153 using executor = hpx::parallel::execution::parallel_executor; in static_check_executor() typedef
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/whitebox/java.net.http/jdk/internal/net/http/common/ |
| H A D | MinimalFutureTest.java | 40 ExecutorService executor = Executors.newSingleThreadExecutor(); in test() local
56 … assertNoObtrusion(mf.thenCombineAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
60 … assertNoObtrusion(mf.thenAcceptBothAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
64 … assertNoObtrusion(mf.runAfterBothAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
71 … assertNoObtrusion(mf.applyToEitherAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
75 … assertNoObtrusion(mf.acceptEitherAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
79 … assertNoObtrusion(mf.runAfterEitherAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/whitebox/java.net.http/jdk/internal/net/http/common/ |
| H A D | MinimalFutureTest.java | 40 ExecutorService executor = Executors.newSingleThreadExecutor(); in test() local
56 … assertNoObtrusion(mf.thenCombineAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
60 … assertNoObtrusion(mf.thenAcceptBothAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
64 … assertNoObtrusion(mf.runAfterBothAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
71 … assertNoObtrusion(mf.applyToEitherAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
75 … assertNoObtrusion(mf.acceptEitherAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
79 … assertNoObtrusion(mf.runAfterEitherAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/net/httpclient/whitebox/java.net.http/jdk/internal/net/http/common/ |
| H A D | MinimalFutureTest.java | 40 ExecutorService executor = Executors.newSingleThreadExecutor(); in test() local
56 … assertNoObtrusion(mf.thenCombineAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
60 … assertNoObtrusion(mf.thenAcceptBothAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
64 … assertNoObtrusion(mf.runAfterBothAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
71 … assertNoObtrusion(mf.applyToEitherAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
75 … assertNoObtrusion(mf.acceptEitherAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
79 … assertNoObtrusion(mf.runAfterEitherAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/net/httpclient/whitebox/java.net.http/jdk/internal/net/http/common/ |
| H A D | MinimalFutureTest.java | 40 ExecutorService executor = Executors.newSingleThreadExecutor(); in test() local
56 … assertNoObtrusion(mf.thenCombineAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
60 … assertNoObtrusion(mf.thenAcceptBothAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
64 … assertNoObtrusion(mf.runAfterBothAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
71 … assertNoObtrusion(mf.applyToEitherAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
75 … assertNoObtrusion(mf.acceptEitherAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
79 … assertNoObtrusion(mf.runAfterEitherAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/net/httpclient/whitebox/java.net.http/jdk/internal/net/http/common/ |
| H A D | MinimalFutureTest.java | 40 ExecutorService executor = Executors.newSingleThreadExecutor(); in test() local
56 … assertNoObtrusion(mf.thenCombineAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
60 … assertNoObtrusion(mf.thenAcceptBothAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
64 … assertNoObtrusion(mf.runAfterBothAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
71 … assertNoObtrusion(mf.applyToEitherAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
75 … assertNoObtrusion(mf.acceptEitherAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
79 … assertNoObtrusion(mf.runAfterEitherAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/net/httpclient/whitebox/java.net.http/jdk/internal/net/http/common/ |
| H A D | MinimalFutureTest.java | 40 ExecutorService executor = Executors.newSingleThreadExecutor(); in test() local
56 … assertNoObtrusion(mf.thenCombineAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
60 … assertNoObtrusion(mf.thenAcceptBothAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
64 … assertNoObtrusion(mf.runAfterBothAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
71 … assertNoObtrusion(mf.applyToEitherAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
75 … assertNoObtrusion(mf.acceptEitherAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
79 … assertNoObtrusion(mf.runAfterEitherAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/net/httpclient/whitebox/java.net.http/jdk/internal/net/http/common/ |
| H A D | MinimalFutureTest.java | 40 ExecutorService executor = Executors.newSingleThreadExecutor(); in test() local
56 … assertNoObtrusion(mf.thenCombineAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
60 … assertNoObtrusion(mf.thenAcceptBothAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
64 … assertNoObtrusion(mf.runAfterBothAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
71 … assertNoObtrusion(mf.applyToEitherAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
75 … assertNoObtrusion(mf.acceptEitherAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
79 … assertNoObtrusion(mf.runAfterEitherAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/net/httpclient/whitebox/java.net.http/jdk/internal/net/http/common/ |
| H A D | MinimalFutureTest.java | 40 ExecutorService executor = Executors.newSingleThreadExecutor(); in test() local
56 … assertNoObtrusion(mf.thenCombineAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
60 … assertNoObtrusion(mf.thenAcceptBothAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
64 … assertNoObtrusion(mf.runAfterBothAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
71 … assertNoObtrusion(mf.applyToEitherAsync(otherFuture(), MinimalFutureTest::apply, executor)); in test() local
75 … assertNoObtrusion(mf.acceptEitherAsync(otherFuture(), MinimalFutureTest::accept, executor)); in test() local
79 … assertNoObtrusion(mf.runAfterEitherAsync(otherFuture(), MinimalFutureTest::run, executor)); in test() local
|
| /dports/www/restbed/restbed-4.8/dependency/asio/asio/src/tests/unit/execution/ |
| H A D | bulk_execute.cpp | 152 struct executor struct
154 executor() in executor() argument
158 executor(const executor&) ASIO_NOEXCEPT in executor() function
163 executor(executor&&) ASIO_NOEXCEPT in executor() function
175 bool operator==(const executor&) const ASIO_NOEXCEPT in operator ==() argument
180 bool operator!=(const executor&) const ASIO_NOEXCEPT in operator !=() argument
|