- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for wait_for (0.19 sec)
-
tensorflow/cc/training/queue_runner.cc
} Status QueueRunner::Start(Session* sess, int wait_for) { counter_.reset(new BlockingCounter(runs_)); for (const string& enqueue_op : enqueue_op_names_) { thread_pool_->Schedule( std::bind(&QueueRunner::Run, this, sess, enqueue_op)); } if (coord_) { thread_pool_->Schedule(std::bind(&QueueRunner::Stop, this, sess)); } // Wait for up to 'wait_for' milliseconds. if (wait_for > 0) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zsysnum_netbsd_arm64.go
SYS__LWP_EXIT = 310 // { int|sys||_lwp_exit(void); } SYS__LWP_SELF = 311 // { lwpid_t|sys||_lwp_self(void); } SYS__LWP_WAIT = 312 // { int|sys||_lwp_wait(lwpid_t wait_for, lwpid_t *departed); } SYS__LWP_SUSPEND = 313 // { int|sys||_lwp_suspend(lwpid_t target); } SYS__LWP_CONTINUE = 314 // { int|sys||_lwp_continue(lwpid_t target); }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 25.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zsysnum_netbsd_386.go
SYS__LWP_EXIT = 310 // { int|sys||_lwp_exit(void); } SYS__LWP_SELF = 311 // { lwpid_t|sys||_lwp_self(void); } SYS__LWP_WAIT = 312 // { int|sys||_lwp_wait(lwpid_t wait_for, lwpid_t *departed); } SYS__LWP_SUSPEND = 313 // { int|sys||_lwp_suspend(lwpid_t target); } SYS__LWP_CONTINUE = 314 // { int|sys||_lwp_continue(lwpid_t target); }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 25.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zsysnum_netbsd_amd64.go
SYS__LWP_EXIT = 310 // { int|sys||_lwp_exit(void); } SYS__LWP_SELF = 311 // { lwpid_t|sys||_lwp_self(void); } SYS__LWP_WAIT = 312 // { int|sys||_lwp_wait(lwpid_t wait_for, lwpid_t *departed); } SYS__LWP_SUSPEND = 313 // { int|sys||_lwp_suspend(lwpid_t target); } SYS__LWP_CONTINUE = 314 // { int|sys||_lwp_continue(lwpid_t target); }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 25.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zsysnum_netbsd_arm.go
SYS__LWP_EXIT = 310 // { int|sys||_lwp_exit(void); } SYS__LWP_SELF = 311 // { lwpid_t|sys||_lwp_self(void); } SYS__LWP_WAIT = 312 // { int|sys||_lwp_wait(lwpid_t wait_for, lwpid_t *departed); } SYS__LWP_SUSPEND = 313 // { int|sys||_lwp_suspend(lwpid_t target); } SYS__LWP_CONTINUE = 314 // { int|sys||_lwp_continue(lwpid_t target); }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 25.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonReuseIntegrationTest.groovy
def client1 = new DaemonClientFixture(executer.withTasks("block").withArguments("--debug", "-PbuildNum=1").start()) waitFor("started1") def canceledDaemon1 = daemons.daemon def client2 = new DaemonClientFixture(executer.withTasks("block").withArguments("--debug", "-PbuildNum=2").start()) waitFor("started2") def canceledDaemon2 = daemons.daemons.find { it.context.pid != canceledDaemon1.context.pid }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 10.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
@SuppressWarnings("unchecked") // proxy for a generic class <V> Callable<V> waitFor(Callable<V> callable) { return waitFor(callable, Callable.class); } @SuppressWarnings("unchecked") // proxy for a generic class <V> ClosingCallable<V> waitFor(ClosingCallable<V> closingCallable) { return waitFor(closingCallable, ClosingCallable.class); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
@SuppressWarnings("unchecked") // proxy for a generic class <V> Callable<V> waitFor(Callable<V> callable) { return waitFor(callable, Callable.class); } @SuppressWarnings("unchecked") // proxy for a generic class <V> ClosingCallable<V> waitFor(ClosingCallable<V> closingCallable) { return waitFor(closingCallable, ClosingCallable.class); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/file/TestFileHelper.groovy
def process = ['unzip', '-q', '-o', file.absolutePath, '-d', target.absolutePath].execute() process.consumeProcessOutput(System.out, System.err) assertThat(process.waitFor(), equalTo(0)) return } def unzip = new Expand() unzip.src = file unzip.dest = target unzip.project = new Project() unzip.execute() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 10.8K bytes - Viewed (0) -
platforms/core-runtime/native/src/testFixtures/groovy/org/gradle/util/WindowsSymbolicLinkUtil.groovy
assert ["cmd.exe", "/d", "/c", "mklink", *extraOptions, link, target].execute().waitFor() == 0 } static void createWindowsJunction(File link, File target) { assert target.isDirectory(), "Windows junction only works on directory" assert ["cmd.exe", "/d", "/c", "mklink", "/j", link, target].execute().waitFor() == 0 } static void createWindowsHardLinks(File link, File target) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 12 10:33:12 UTC 2024 - 1.8K bytes - Viewed (0)