| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/services/sharing/nearby/platform/ |
| H A D | submittable_executor.cc | 53 bool SubmittableExecutor::DoSubmit(Runnable&& runnable) { in DoSubmit() argument
61 base::Unretained(this), std::move(runnable))); in DoSubmit()
66 void SubmittableExecutor::Execute(Runnable&& runnable) { in Execute() argument
74 base::Unretained(this), std::move(runnable))); in Execute()
77 void SubmittableExecutor::RunTask(Runnable&& runnable) { in RunTask() argument
82 runnable(); in RunTask()
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.ui/bundles/org.eclipse.core.databinding.observable/src/org/eclipse/core/databinding/observable/sideeffect/ |
| H A D | ISideEffect.java | 234 static ISideEffect createPaused(Runnable runnable) { in createPaused() argument
235 return new SideEffect(runnable); in createPaused()
251 static ISideEffect createPaused(Realm realm, Runnable runnable) { in createPaused() argument
252 return new SideEffect(realm, runnable); in createPaused()
271 static ISideEffect create(Runnable runnable) { in create() argument
272 IObservable[] dependencies = ObservableTracker.runAndMonitor(runnable, null, null); in create()
278 return new SideEffect(runnable, dependencies); in create()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/mobile/android/geckoview/src/main/java/org/mozilla/gecko/util/ |
| H A D | ThreadUtils.java | 56 public static void runOnUiThread(final Runnable runnable) { in runOnUiThread() argument
59 runnable.run(); in runOnUiThread()
63 postToUiThread(runnable); in runOnUiThread()
66 public static void postToUiThread(final Runnable runnable) { in postToUiThread() argument
67 sUiHandler.post(runnable); in postToUiThread()
78 public static void postToBackgroundThread(final Runnable runnable) { in postToBackgroundThread() argument
79 GeckoBackgroundThread.post(runnable); in postToBackgroundThread()
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ForkJoinTask.java | 1378 final Runnable runnable; field in ForkJoinTask.AdaptedRunnable
1380 AdaptedRunnable(Runnable runnable, T result) { in AdaptedRunnable() argument
1382 this.runnable = runnable; in AdaptedRunnable()
1400 final Runnable runnable; field in ForkJoinTask.AdaptedRunnableAction
1401 AdaptedRunnableAction(Runnable runnable) { in AdaptedRunnableAction() argument
1403 this.runnable = runnable; in AdaptedRunnableAction()
1419 final Runnable runnable; field in ForkJoinTask.RunnableExecuteAction
1420 RunnableExecuteAction(Runnable runnable) { in RunnableExecuteAction() argument
1422 this.runnable = runnable; in RunnableExecuteAction()
1472 return new AdaptedRunnableAction(runnable); in adapt()
[all …]
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ForkJoinTask.java | 1377 final Runnable runnable; field in ForkJoinTask.AdaptedRunnable
1379 AdaptedRunnable(Runnable runnable, T result) { in AdaptedRunnable() argument
1381 this.runnable = runnable; in AdaptedRunnable()
1399 final Runnable runnable; field in ForkJoinTask.AdaptedRunnableAction
1400 AdaptedRunnableAction(Runnable runnable) { in AdaptedRunnableAction() argument
1402 this.runnable = runnable; in AdaptedRunnableAction()
1418 final Runnable runnable; field in ForkJoinTask.RunnableExecuteAction
1419 RunnableExecuteAction(Runnable runnable) { in RunnableExecuteAction() argument
1421 this.runnable = runnable; in RunnableExecuteAction()
1471 return new AdaptedRunnableAction(runnable); in adapt()
[all …]
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ForkJoinTask.java | 1378 final Runnable runnable; field in ForkJoinTask.AdaptedRunnable
1380 AdaptedRunnable(Runnable runnable, T result) { in AdaptedRunnable() argument
1382 this.runnable = runnable; in AdaptedRunnable()
1400 final Runnable runnable; field in ForkJoinTask.AdaptedRunnableAction
1401 AdaptedRunnableAction(Runnable runnable) { in AdaptedRunnableAction() argument
1403 this.runnable = runnable; in AdaptedRunnableAction()
1419 final Runnable runnable; field in ForkJoinTask.RunnableExecuteAction
1420 RunnableExecuteAction(Runnable runnable) { in RunnableExecuteAction() argument
1422 this.runnable = runnable; in RunnableExecuteAction()
1472 return new AdaptedRunnableAction(runnable); in adapt()
[all …]
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ForkJoinTask.java | 1377 final Runnable runnable; field in ForkJoinTask.AdaptedRunnable
1379 AdaptedRunnable(Runnable runnable, T result) { in AdaptedRunnable() argument
1381 this.runnable = runnable; in AdaptedRunnable()
1399 final Runnable runnable; field in ForkJoinTask.AdaptedRunnableAction
1400 AdaptedRunnableAction(Runnable runnable) { in AdaptedRunnableAction() argument
1402 this.runnable = runnable; in AdaptedRunnableAction()
1418 final Runnable runnable; field in ForkJoinTask.RunnableExecuteAction
1419 RunnableExecuteAction(Runnable runnable) { in RunnableExecuteAction() argument
1421 this.runnable = runnable; in RunnableExecuteAction()
1471 return new AdaptedRunnableAction(runnable); in adapt()
[all …]
|
| /dports/devel/qtcreator/qt-creator-opensource-src-5.0.3/src/plugins/remotelinux/ |
| H A D | linuxdevice.cpp | 133 Runnable runnable(QAbstractSocket::NetworkLayerProtocol protocol) const override in runnable() function in RemoteLinux::LinuxPortsGatheringMethod
146 Runnable runnable; in runnable()
147 runnable.executable = FilePath::fromString("sed"); in runnable()
148 runnable.commandLineArguments in runnable()
150 return runnable; in runnable()
205 Runnable runnable; in LinuxDevice() local
206 runnable.device = sharedFromThis(); in LinuxDevice()
207 runnable.environment = env; in LinuxDevice()
208 runnable.workingDirectory = workingDir; in LinuxDevice()
213 runnable.executable = FilePath::fromString("/bin/sh"); in LinuxDevice()
[all …]
|
| /dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/internal/ |
| H A D | ThreadPool.java | 47 private Runnable runnable; field in ThreadPool
62 public ThreadPool(StageWrapperIF stage, ManagerIF mgr, Runnable runnable) { in ThreadPool() argument
66 this.runnable = runnable; in ThreadPool()
114 public ThreadPool(StageWrapperIF stage, ManagerIF mgr, Runnable runnable, in ThreadPool() argument
119 this.runnable = runnable; in ThreadPool()
147 public ThreadPool(StageWrapperIF stage, ManagerIF mgr, Runnable runnable, in ThreadPool() argument
152 this.runnable = runnable; in ThreadPool()
209 Thread t = new Thread(pooltg, runnable, name); in addThreads()
|
| /dports/devel/qtcreator/qt-creator-opensource-src-5.0.3/src/plugins/qnx/ |
| H A D | qnxdeviceprocess.cpp | 47 QString QnxDeviceProcess::fullCommandLine(const Runnable &runnable) const in fullCommandLine()
49 QStringList args = ProcessArgs::splitArgs(runnable.commandLineArguments); in fullCommandLine()
50 args.prepend(runnable.executable.toString()); in fullCommandLine()
57 if (!runnable.workingDirectory.isEmpty()) in fullCommandLine()
58 …fullCommandLine += QString::fromLatin1("cd %1 ; ").arg(ProcessArgs::quoteArg(runnable.workingDirec… in fullCommandLine()
60 const Environment env = runnable.environment; in fullCommandLine()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/android/feed/core/java/src/org/chromium/chrome/browser/feed/library/common/concurrent/testing/ |
| H A D | FakeMainThreadRunner.java | 81 public void execute(String name, Runnable runnable) { in execute() argument
82 mTasksToRun.add(runnable); in execute()
89 public CancelableTask executeWithDelay(String name, Runnable runnable, long delayMs) { in executeWithDelay() argument
90 CancelableRunnableTask cancelable = new CancelableRunnableTask(runnable); in executeWithDelay()
120 for (TimedRunnable runnable : mDelayedTasks) { in hasPendingTasks()
121 if (!runnable.isCanceled()) { in hasPendingTasks()
143 private TimedRunnable(CancelableRunnableTask runnable, long executeTime) { in TimedRunnable() argument
144 this.mRunnable = runnable; in TimedRunnable()
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/gfx/layers/ipc/ |
| H A D | ImageBridgeChild.cpp | 434 RefPtr<Runnable> runnable = WrapRunnable( in ReleaseImageContainer() local
471 RefPtr<Runnable> runnable = WrapRunnable( in DispatchReleaseTextureClient() local
486 RefPtr<Runnable> runnable = WrapRunnable( in UpdateImageClient() local
530 RefPtr<Runnable> runnable = WrapRunnable( in UpdateAsyncCanvasRenderer() local
588 RefPtr<Runnable> runnable = WrapRunnable( in FlushAllImages() local
758 RefPtr<Runnable> runnable = WrapRunnable( in WillShutdown() local
796 RefPtr<Runnable> runnable = WrapRunnable( in InitSameProcess() local
866 RefPtr<Runnable> runnable = WrapRunnable( in CreateImageClient() local
918 RefPtr<Runnable> runnable = WrapRunnable( in CreateCanvasClient() local
1015 RefPtr<Runnable> runnable = WrapRunnable( in DispatchAllocShmemInternal() local
[all …]
|
| /dports/devel/qtcreator/qt-creator-opensource-src-5.0.3/src/plugins/projectexplorer/devicesupport/ |
| H A D | sshdeviceprocess.cpp | 57 Runnable runnable; member in ProjectExplorer::SshDeviceProcess::SshDeviceProcessPrivate
72 return runnable.extraData.value("Ssh.X11ForwardToDisplay").toString(); in displayName()
87 void SshDeviceProcess::start(const Runnable &runnable) in start() argument
90 QTC_ASSERT(runInTerminal() || !runnable.executable.isEmpty(), return); in start()
96 d->runnable = runnable; in start()
190 d->process = runInTerminal() && d->runnable.executable.isEmpty() in handleConnected()
301 QString SshDeviceProcess::fullCommandLine(const Runnable &runnable) const in fullCommandLine()
303 QString cmdLine = runnable.executable.toString(); in fullCommandLine()
304 if (!runnable.commandLineArguments.isEmpty()) in fullCommandLine()
311 if (runnable.executable.isEmpty()) in doSignal()
[all …]
|
| /dports/lang/spidermonkey60/firefox-60.9.0/netwerk/protocol/websocket/ |
| H A D | WebSocketEventService.cpp | 232 : NS_DispatchToMainThread(runnable); in WebSocketCreated()
247 RefPtr<WebSocketOpenedRunnable> runnable = in WebSocketOpened() local
252 : NS_DispatchToMainThread(runnable); in WebSocketOpened()
264 RefPtr<WebSocketMessageAvailableRunnable> runnable = in WebSocketMessageAvailable() local
269 : NS_DispatchToMainThread(runnable); in WebSocketMessageAvailable()
283 RefPtr<WebSocketClosedRunnable> runnable = new WebSocketClosedRunnable( in WebSocketClosed() local
287 : NS_DispatchToMainThread(runnable); in WebSocketClosed()
302 RefPtr<WebSocketFrameRunnable> runnable = in FrameReceived() local
307 : NS_DispatchToMainThread(runnable); in FrameReceived()
323 RefPtr<WebSocketFrameRunnable> runnable = new WebSocketFrameRunnable( in FrameSent() local
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/netwerk/protocol/websocket/ |
| H A D | WebSocketEventService.cpp | 236 : NS_DispatchToMainThread(runnable); in WebSocketCreated()
252 RefPtr<WebSocketOpenedRunnable> runnable = new WebSocketOpenedRunnable( in WebSocketOpened() local
257 : NS_DispatchToMainThread(runnable); in WebSocketOpened()
269 RefPtr<WebSocketMessageAvailableRunnable> runnable = in WebSocketMessageAvailable() local
274 : NS_DispatchToMainThread(runnable); in WebSocketMessageAvailable()
288 RefPtr<WebSocketClosedRunnable> runnable = new WebSocketClosedRunnable( in WebSocketClosed() local
292 : NS_DispatchToMainThread(runnable); in WebSocketClosed()
307 RefPtr<WebSocketFrameRunnable> runnable = in FrameReceived() local
312 : NS_DispatchToMainThread(runnable); in FrameReceived()
328 RefPtr<WebSocketFrameRunnable> runnable = new WebSocketFrameRunnable( in FrameSent() local
[all …]
|
| /dports/net/gtk-vnc/gtk-vnc-0.7.2/src/ |
| H A D | coroutine_gthread.c | 58 leader.runnable = TRUE; /* we're the one running right now */ in coroutine_system_init()
70 while (!co->runnable) { in coroutine_thread()
80 co->caller->runnable = TRUE; in coroutine_thread()
103 co->runnable = FALSE; in coroutine_init()
116 from->runnable = FALSE; in coroutine_swap()
117 to->runnable = TRUE; in coroutine_swap()
126 while (!from->runnable) { in coroutine_swap()
|
| /dports/deskutils/spice-gtk/spice-gtk-0.37/src/ |
| H A D | coroutine_gthread.c | 58 leader.runnable = TRUE; /* we're the one running right now */ in coroutine_system_init()
70 while (!co->runnable) { in coroutine_thread()
80 co->caller->runnable = TRUE; in coroutine_thread()
96 co->runnable = FALSE; in coroutine_init()
107 from->runnable = FALSE; in coroutine_swap()
108 to->runnable = TRUE; in coroutine_swap()
117 while (!from->runnable) { in coroutine_swap()
|
| /dports/www/firefox-esr/firefox-91.8.0/ipc/mscom/ |
| H A D | MainThreadInvoker.cpp | 126 nsCOMPtr<nsIRunnable> runnable(std::move(aRunnable)); in Invoke() local
127 if (!runnable) { in Invoke()
132 runnable->Run(); in Invoke()
136 RefPtr<SyncRunnable> syncRunnable = new SyncRunnable(runnable.forget()); in Invoke()
171 auto runnable = reinterpret_cast<SyncRunnable*>(aParam); in MainThreadAPC() local
172 runnable->APCRun(); in MainThreadAPC()
173 NS_RELEASE(runnable); in MainThreadAPC()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/ipc/mscom/ |
| H A D | MainThreadInvoker.cpp | 126 nsCOMPtr<nsIRunnable> runnable(std::move(aRunnable)); in Invoke() local
127 if (!runnable) { in Invoke()
132 runnable->Run(); in Invoke()
136 RefPtr<SyncRunnable> syncRunnable = new SyncRunnable(runnable.forget()); in Invoke()
171 auto runnable = reinterpret_cast<SyncRunnable*>(aParam); in MainThreadAPC() local
172 runnable->APCRun(); in MainThreadAPC()
173 NS_RELEASE(runnable); in MainThreadAPC()
|
| /dports/www/firefox/firefox-99.0/ipc/mscom/ |
| H A D | MainThreadInvoker.cpp | 126 nsCOMPtr<nsIRunnable> runnable(std::move(aRunnable)); in Invoke() local
127 if (!runnable) { in Invoke()
132 runnable->Run(); in Invoke()
136 RefPtr<SyncRunnable> syncRunnable = new SyncRunnable(runnable.forget()); in Invoke()
171 auto runnable = reinterpret_cast<SyncRunnable*>(aParam); in MainThreadAPC() local
172 runnable->APCRun(); in MainThreadAPC()
173 NS_RELEASE(runnable); in MainThreadAPC()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/ipc/mscom/ |
| H A D | MainThreadInvoker.cpp | 126 nsCOMPtr<nsIRunnable> runnable(std::move(aRunnable)); in Invoke() local
127 if (!runnable) { in Invoke()
132 runnable->Run(); in Invoke()
136 RefPtr<SyncRunnable> syncRunnable = new SyncRunnable(runnable.forget()); in Invoke()
171 auto runnable = reinterpret_cast<SyncRunnable*>(aParam); in MainThreadAPC() local
172 runnable->APCRun(); in MainThreadAPC()
173 NS_RELEASE(runnable); in MainThreadAPC()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/ipc/mscom/ |
| H A D | MainThreadInvoker.cpp | 123 nsCOMPtr<nsIRunnable> runnable(Move(aRunnable)); in Invoke() local
124 if (!runnable) { in Invoke()
129 runnable->Run(); in Invoke()
133 RefPtr<SyncRunnable> syncRunnable = new SyncRunnable(runnable.forget()); in Invoke()
168 auto runnable = reinterpret_cast<SyncRunnable*>(aParam); in MainThreadAPC() local
169 runnable->APCRun(); in MainThreadAPC()
170 NS_RELEASE(runnable); in MainThreadAPC()
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/test/lib/testlibrary/jdk/testlibrary/ |
| H A D | TestThread.java | 50 private final Runnable runnable; field in TestThread
59 return runnable; in getRunnable()
70 this.runnable = target; in TestThread()
80 this.runnable = target; in TestThread()
94 this.runnable = target; in TestThread()
106 this.runnable = target; in TestThread()
117 this.runnable = target; in TestThread()
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/lib/testlibrary/jdk/testlibrary/ |
| H A D | TestThread.java | 50 private final Runnable runnable; field in TestThread
59 return runnable; in getRunnable()
70 this.runnable = target; in TestThread()
80 this.runnable = target; in TestThread()
94 this.runnable = target; in TestThread()
106 this.runnable = target; in TestThread()
117 this.runnable = target; in TestThread()
|
| /dports/security/zaproxy/zaproxy-2.11.1/zap/src/main/java/org/zaproxy/zap/utils/ |
| H A D | ThreadUtils.java | 50 public static void invokeAndWait(Runnable runnable) in invokeAndWait() argument
53 runnable.run(); in invokeAndWait()
55 EventQueue.invokeAndWait(runnable); in invokeAndWait()
68 public static void invokeAndWaitHandled(Runnable runnable) { in invokeAndWaitHandled() argument
70 invokeAndWait(runnable); in invokeAndWaitHandled()
|