- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for StartThread (0.19 sec)
-
guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.util.concurrent.GeneratedMonitorTest.startThread; import static com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly; import static org.junit.Assert.assertThrows; import com.google.common.util.concurrent.GeneratedMonitorTest.FlagGuard;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.util.concurrent.GeneratedMonitorTest.startThread; import static com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly; import static org.junit.Assert.assertThrows; import com.google.common.util.concurrent.GeneratedMonitorTest.FlagGuard;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
@Override public void run() { runChosenTest(); } }; final FutureTask<@Nullable Void> task = new FutureTask<>(runChosenTest, null); startThread( new Runnable() { @Override public void run() { task.run(); } }); awaitUninterruptibly(doingCallLatch); long hangDelayMillis =
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 14:48:57 GMT 2023 - 27.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
@Override public void run() { runChosenTest(); } }; final FutureTask<@Nullable Void> task = new FutureTask<>(runChosenTest, null); startThread( new Runnable() { @Override public void run() { task.run(); } }); awaitUninterruptibly(doingCallLatch); long hangDelayMillis =
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 17 14:48:57 GMT 2023 - 26.1K bytes - Viewed (0) -
tensorflow/c/env.cc
} void TF_DefaultThreadOptions(TF_ThreadOptions* options) { options->stack_size = 0; options->guard_size = 0; options->numa_node = -1; } TF_Thread* TF_StartThread(const TF_ThreadOptions* options, const char* thread_name, void (*work_func)(void*), void* param) { ::tensorflow::ThreadOptions cc_options;
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Wed Aug 11 01:20:50 GMT 2021 - 7K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.h
if (max_staleness_ > 0) { TF_ThreadOptions thread_options; TF_DefaultThreadOptions(&thread_options); pruning_thread_.reset( TF_StartThread(&thread_options, "TF_prune_FBC", PruneThread, this)); } TF_VLog(1, "GCS file block cache is %s.\n", (IsCacheEnabled() ? "enabled" : "disabled")); } ~RamFileBlockCache() {
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 04:46:34 GMT 2020 - 10.6K bytes - Viewed (0) -
tensorflow/c/env_test.cc
} } // namespace TEST(TestEnv, TestThreads) { TF_ThreadOptions options; TF_DefaultThreadOptions(&options); SomeThreadData data; TF_Thread* thread = TF_StartThread(&options, "SomeThreadName", &SomeThreadFunc, &data); TF_JoinThread(thread); ::tensorflow::mutex_lock l(data.mu); ASSERT_TRUE(data.did_work);
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Dec 10 20:52:48 GMT 2018 - 4.2K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
std::vector<std::unique_ptr<Thread>> threads; threads.reserve(callers); for (int i = 0; i < callers; i++) { threads.emplace_back( Env::Default()->StartThread({}, "caller", [block_size, &cache, i]() { std::vector<char> out; TF_EXPECT_OK( ReadCache(&cache, "a", i * block_size, block_size, &out)); std::vector<char> x(block_size, 'x');
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Oct 15 03:16:57 GMT 2021 - 23.2K bytes - Viewed (0) -
tensorflow/c/env.h
// starts. In this way, data may be passed from the thread back to the caller. // // Caller takes ownership of the result and must call TF_JoinThread on it // eventually. TF_CAPI_EXPORT extern TF_Thread* TF_StartThread(const TF_ThreadOptions* options, const char* thread_name, void (*work_func)(void*),
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Sat Jan 09 02:53:27 GMT 2021 - 9.6K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
TFE_NewExecutor(is_async, /*enable_streaming_enqueue=*/true, /*in_flight_nodes_limit=*/in_flight_nodes_limit)), op_(nullptr), thread_(tensorflow::Env::Default()->StartThread( tensorflow::ThreadOptions(), "parallel_device_execute", std::bind(&DeviceThread::Run, this))) {} ~DeviceThread(); // Requests that the worker thread execute the specified operation. Blocks
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Feb 09 07:47:20 GMT 2024 - 25.4K bytes - Viewed (1)