Home
last modified time | relevance | path

Searched refs:ThreadExecutor (Results 1 – 25 of 48) sorted by relevance

12

/dports/net/gerbera/gerbera-1.9.2/src/util/
H A Dthread_executor.h43 class ThreadExecutor : public Executor {
45 ThreadExecutor() = default;
46 ~ThreadExecutor() override;
48 ThreadExecutor(const ThreadExecutor&) = delete;
49 ThreadExecutor& operator=(const ThreadExecutor&) = delete;
H A Dthread_executor.cc34 ThreadExecutor::~ThreadExecutor() in ~ThreadExecutor()
39 void ThreadExecutor::startThread() in startThread()
44 ThreadExecutor::staticThreadProc, in startThread()
54 bool ThreadExecutor::kill() in kill()
72 void* ThreadExecutor::staticThreadProc(void* arg) in staticThreadProc()
74 auto inst = static_cast<ThreadExecutor*>(arg); in staticThreadProc()
/dports/devel/cppcheck-gui/cppcheck-2.6.3/cli/
H A Dthreadexecutor.cpp56 ThreadExecutor::ThreadExecutor(const std::map<std::string, std::size_t> &files, Settings &settings,… in ThreadExecutor() function in ThreadExecutor
70 ThreadExecutor::~ThreadExecutor() in ~ThreadExecutor()
150 bool ThreadExecutor::checkLoadAverage(size_t nchildren) in checkLoadAverage()
170 unsigned int ThreadExecutor::check() in check()
349 void ThreadExecutor::reportErr(const ErrorMessage &msg) in reportErr()
354 void ThreadExecutor::reportInfo(const ErrorMessage &msg) in reportInfo()
386 unsigned int ThreadExecutor::check() in check()
417 unsigned int __stdcall ThreadExecutor::threadProc(ThreadExecutor* threadExecutor) in threadProc()
479 void ThreadExecutor::reportErr(const ErrorMessage &msg) in reportErr()
484 void ThreadExecutor::reportInfo(const ErrorMessage &msg) in reportInfo()
[all …]
H A Dthreadexecutor.h48 class ThreadExecutor : public ErrorLogger {
50 …ThreadExecutor(const std::map<std::string, std::size_t> &files, Settings &settings, ErrorLogger &e…
51 ThreadExecutor(const ThreadExecutor &) = delete;
52 ~ThreadExecutor() OVERRIDE;
53 void operator=(const ThreadExecutor &) = delete;
140 static unsigned __stdcall threadProc(ThreadExecutor *threadExecutor);
/dports/devel/cppcheck/cppcheck-2.6.3/cli/
H A Dthreadexecutor.cpp56 ThreadExecutor::ThreadExecutor(const std::map<std::string, std::size_t> &files, Settings &settings,… in ThreadExecutor() function in ThreadExecutor
70 ThreadExecutor::~ThreadExecutor() in ~ThreadExecutor()
150 bool ThreadExecutor::checkLoadAverage(size_t nchildren) in checkLoadAverage()
170 unsigned int ThreadExecutor::check() in check()
349 void ThreadExecutor::reportErr(const ErrorMessage &msg) in reportErr()
354 void ThreadExecutor::reportInfo(const ErrorMessage &msg) in reportInfo()
386 unsigned int ThreadExecutor::check() in check()
417 unsigned int __stdcall ThreadExecutor::threadProc(ThreadExecutor* threadExecutor) in threadProc()
479 void ThreadExecutor::reportErr(const ErrorMessage &msg) in reportErr()
484 void ThreadExecutor::reportInfo(const ErrorMessage &msg) in reportInfo()
[all …]
H A Dthreadexecutor.h48 class ThreadExecutor : public ErrorLogger {
50 …ThreadExecutor(const std::map<std::string, std::size_t> &files, Settings &settings, ErrorLogger &e…
51 ThreadExecutor(const ThreadExecutor &) = delete;
52 ~ThreadExecutor() OVERRIDE;
53 void operator=(const ThreadExecutor &) = delete;
140 static unsigned __stdcall threadProc(ThreadExecutor *threadExecutor);
/dports/misc/glow/glow-f24d960e3cc80db95ac0bc17b1900dbf60ca044a/lib/Support/
H A DThreadPool.cpp34 ThreadExecutor::ThreadExecutor(const std::string &name) in ThreadExecutor() function in glow::ThreadExecutor
42 ThreadExecutor::~ThreadExecutor() { stop(true); } in ~ThreadExecutor()
44 void ThreadExecutor::stop(bool block) { in stop()
59 void ThreadExecutor::threadPoolWorkerMain() { in threadPoolWorkerMain()
90 ThreadExecutor::submit(std::packaged_task<void(void)> &&task) { in submit()
103 workers_.push_back(new ThreadExecutor(name)); in ThreadPool()
128 ThreadExecutor *ex = getExecutor(); in submit()
/dports/misc/glow/glow-f24d960e3cc80db95ac0bc17b1900dbf60ca044a/include/glow/Support/
H A DThreadPool.h64 class ThreadExecutor final {
67 explicit ThreadExecutor(const std::string &name = "");
70 ~ThreadExecutor();
149 ThreadExecutor *getExecutor() { in getExecutor()
182 std::vector<ThreadExecutor *> workers_;
/dports/devel/cppcheck-gui/cppcheck-2.6.3/test/
H A Dtestthreadexecutor.cpp41 if (!ThreadExecutor::isEnabled()) { in check()
54 ThreadExecutor executor(filemap, settings, *this); in check()
/dports/devel/cppcheck/cppcheck-2.6.3/test/
H A Dtestthreadexecutor.cpp41 if (!ThreadExecutor::isEnabled()) { in check()
54 ThreadExecutor executor(filemap, settings, *this); in check()
/dports/misc/orange3/orange3-3.29.1/Orange/widgets/utils/tests/
H A Dtest_concurrent.py8 from Orange.widgets.utils.concurrent import ThreadExecutor, Task
69 executor = ThreadExecutor()
/dports/devel/folly/folly-2021.12.27.00/folly/futures/test/
H A DViaTest.cpp345 class ThreadExecutor : public Executor { class
363 explicit ThreadExecutor(size_t n = 1024) : funcs(n) { in ThreadExecutor() function in ThreadExecutor
364 worker = std::thread(std::bind(&ThreadExecutor::work, this)); in ThreadExecutor()
367 ~ThreadExecutor() override { in ~ThreadExecutor()
379 ThreadExecutor x; in TEST()
389 ThreadExecutor x; in TEST()
/dports/net/gerbera/gerbera-1.9.2/src/iohandler/
H A Dio_handler_chainer.h46 class IOHandlerChainer : public ThreadExecutor {
/dports/devel/py-graphql-core2/graphql-core-2.2.1/graphql/execution/executors/
H A Dthread.py12 class ThreadExecutor(object): class
/dports/misc/orange3/orange3-3.29.1/doc/development/source/
H A Dconcurrent.rst8 .. autoclass:: ThreadExecutor
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/util/concurrent/tck/
H A DCompletableFutureTest.java628 static final class ThreadExecutor implements Executor {
651 assertFalse(ThreadExecutor.startedCurrentThread());
818 assertTrue(ThreadExecutor.startedCurrentThread());
828 return f.thenRunAsync(a, new ThreadExecutor());
832 return f.thenAcceptAsync(a, new ThreadExecutor());
836 return f.thenApplyAsync(a, new ThreadExecutor());
841 return f.thenComposeAsync(a, new ThreadExecutor());
846 return f.handleAsync(a, new ThreadExecutor());
3466 ThreadExecutor exec = new ThreadExecutor(); in testNPE()
3926 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3()
[all …]
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/util/concurrent/tck/
H A DCompletableFutureTest.java628 static final class ThreadExecutor implements Executor {
651 assertFalse(ThreadExecutor.startedCurrentThread());
818 assertTrue(ThreadExecutor.startedCurrentThread());
828 return f.thenRunAsync(a, new ThreadExecutor());
832 return f.thenAcceptAsync(a, new ThreadExecutor());
836 return f.thenApplyAsync(a, new ThreadExecutor());
841 return f.thenComposeAsync(a, new ThreadExecutor());
846 return f.handleAsync(a, new ThreadExecutor());
3466 ThreadExecutor exec = new ThreadExecutor(); in testNPE()
3926 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3()
[all …]
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/util/concurrent/tck/
H A DCompletableFutureTest.java628 static final class ThreadExecutor implements Executor {
651 assertFalse(ThreadExecutor.startedCurrentThread());
818 assertTrue(ThreadExecutor.startedCurrentThread());
828 return f.thenRunAsync(a, new ThreadExecutor());
832 return f.thenAcceptAsync(a, new ThreadExecutor());
836 return f.thenApplyAsync(a, new ThreadExecutor());
841 return f.thenComposeAsync(a, new ThreadExecutor());
846 return f.handleAsync(a, new ThreadExecutor());
3466 ThreadExecutor exec = new ThreadExecutor(); in testNPE()
3926 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3()
[all …]
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/util/concurrent/tck/
H A DCompletableFutureTest.java628 static final class ThreadExecutor implements Executor {
651 assertFalse(ThreadExecutor.startedCurrentThread());
818 assertTrue(ThreadExecutor.startedCurrentThread());
828 return f.thenRunAsync(a, new ThreadExecutor());
832 return f.thenAcceptAsync(a, new ThreadExecutor());
836 return f.thenApplyAsync(a, new ThreadExecutor());
841 return f.thenComposeAsync(a, new ThreadExecutor());
846 return f.handleAsync(a, new ThreadExecutor());
3466 ThreadExecutor exec = new ThreadExecutor(); in testNPE()
3926 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3()
[all …]
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/util/concurrent/tck/
H A DCompletableFutureTest.java628 static final class ThreadExecutor implements Executor {
651 assertFalse(ThreadExecutor.startedCurrentThread());
818 assertTrue(ThreadExecutor.startedCurrentThread());
828 return f.thenRunAsync(a, new ThreadExecutor());
832 return f.thenAcceptAsync(a, new ThreadExecutor());
836 return f.thenApplyAsync(a, new ThreadExecutor());
841 return f.thenComposeAsync(a, new ThreadExecutor());
846 return f.handleAsync(a, new ThreadExecutor());
3478 ThreadExecutor exec = new ThreadExecutor(); in testNPE()
3928 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3()
[all …]
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/util/concurrent/tck/
H A DCompletableFutureTest.java628 static final class ThreadExecutor implements Executor {
651 assertFalse(ThreadExecutor.startedCurrentThread());
818 assertTrue(ThreadExecutor.startedCurrentThread());
828 return f.thenRunAsync(a, new ThreadExecutor());
832 return f.thenAcceptAsync(a, new ThreadExecutor());
836 return f.thenApplyAsync(a, new ThreadExecutor());
841 return f.thenComposeAsync(a, new ThreadExecutor());
846 return f.handleAsync(a, new ThreadExecutor());
3466 ThreadExecutor exec = new ThreadExecutor(); in testNPE()
3926 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3()
[all …]
/dports/misc/orange3/orange3-3.29.1/Orange/widgets/model/
H A Downeuralnetwork.py20 from Orange.widgets.utils.concurrent import ThreadExecutor, FutureWatcher
160 self._executor = ThreadExecutor()
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/util/concurrent/tck/
H A DCompletableFutureTest.java601 static final class ThreadExecutor implements Executor {
624 assertFalse(ThreadExecutor.startedCurrentThread());
772 assertTrue(ThreadExecutor.startedCurrentThread());
782 return f.thenRunAsync(a, new ThreadExecutor());
786 return f.thenAcceptAsync(a, new ThreadExecutor());
790 return f.thenApplyAsync(a, new ThreadExecutor());
795 return f.thenComposeAsync(a, new ThreadExecutor());
800 return f.handleAsync(a, new ThreadExecutor());
3287 ThreadExecutor exec = new ThreadExecutor(); in testNPE()
3753 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3()
[all …]
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/util/concurrent/tck/
H A DCompletableFutureTest.java601 static final class ThreadExecutor implements Executor {
624 assertFalse(ThreadExecutor.startedCurrentThread());
772 assertTrue(ThreadExecutor.startedCurrentThread());
782 return f.thenRunAsync(a, new ThreadExecutor());
786 return f.thenAcceptAsync(a, new ThreadExecutor());
790 return f.thenApplyAsync(a, new ThreadExecutor());
795 return f.thenComposeAsync(a, new ThreadExecutor());
800 return f.handleAsync(a, new ThreadExecutor());
3287 ThreadExecutor exec = new ThreadExecutor(); in testNPE()
3753 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3()
[all …]
/dports/biology/py-orange3-bioinformatics/Orange3-Bioinformatics-4.3.1/orangecontrib/bioinformatics/cluster_analysis/
H A D__init__.py13 from Orange.widgets.utils.concurrent import FutureWatcher, ThreadExecutor, methodinvoke
278 self._executor = ThreadExecutor()

12