- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 299 for task (5 sec)
-
tensorflow/c/eager/parallel_device/parallel_device_lib.h
TF_Status* status) const; void AsyncWait(TFE_Context* context, TF_Status* status) const; // Device strings for component devices that only include a // worker/task/replica if any of those differ across components. Useful for // printing debug messages. std::vector<std::string> SummarizeDeviceNames() const; private:
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Apr 25 15:21:13 GMT 2023 - 12.9K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.h
// custom devices will fail. // // `device_name` must not name an existing physical or custom device. It must // follow the format: // // /job:<name>/replica:<replica>/task:<task>/device:<type>:<device_num> // // If the device is successfully registered, `status` is set to TF_OK. Otherwise // the device is not usable. In case of a bad status, `device.delete_device` is
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Feb 21 22:37:46 GMT 2024 - 39.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
public void destroy() { shutdownHookList.forEach(action -> { try { action.run(); } catch (final Exception e) { logger.warn("Failed to process shutdown task.", e); } }); } public String getUsername() { final RequestManager requestManager = ComponentUtil.getRequestManager();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sat Apr 13 11:43:03 GMT 2024 - 26.5K bytes - Viewed (2) -
android/guava-tests/benchmark/com/google/common/collect/ConcurrentHashMultisetBenchmark.java
} }); } private long doMultithreadedLoop(Callable<Long> task) throws InterruptedException, ExecutionException { List<Future<Long>> futures = Lists.newArrayListWithCapacity(threads); for (int i = 0; i < threads; i++) { futures.add(threadPool.submit(task)); } long total = 0; for (Future<Long> future : futures) { total += future.get(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 16.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* wait for 100 seconds, and /then/ start the actual task. Why wait without doing anything? A much * better approach is to /allow/ the request right away (as if it was an acquire(1) request * instead), and postpone /subsequent/ requests as needed. In this version, we allow starting the * task immediately, and postpone by 100 seconds future requests, thus we allow for work to get
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 19.3K bytes - Viewed (0) -
api/go1.11.txt
pkg runtime/trace, func NewTask(context.Context, string) (context.Context, *Task) pkg runtime/trace, func StartRegion(context.Context, string) *Region pkg runtime/trace, func WithRegion(context.Context, string, func()) pkg runtime/trace, method (*Region) End() pkg runtime/trace, method (*Task) End() pkg runtime/trace, type Region struct pkg runtime/trace, type Task struct pkg syscall (netbsd-386), func Accept4(int, int) (int, Sockaddr, error)
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Wed Aug 22 03:48:56 GMT 2018 - 25K bytes - Viewed (2) -
cmd/peer-s3-client.go
// buckets only and not the quourum lost ones like this, so // explicit call for bktName, count := range bucketsMap { if count < quorum { // Queue a bucket heal task globalMRFState.addPartialOp(partialOperation{ bucket: bktName, queued: time.Now(), }) } } } result := make([]BucketInfo, 0, len(resultMap))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
class ConnectionPoolTest { private val routePlanner = FakeRoutePlanner() private val factory = routePlanner.factory private val taskFaker = routePlanner.taskFaker private val peer = MockHttp2Peer() /** The fake task runner prevents the cleanup runnable from being started. */ private val addressA = factory.newAddress("a") private val routeA1 = factory.newRoute(addressA) private val addressB = factory.newAddress("b")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
.teamcity/src/main/kotlin/common/extensions.kt
listOf( // We pass the 'maxParallelForks' setting as 'workers.max' to limit the maximum number of executers even // if multiple test tasks run in parallel. We also pass it to the Gradle build as a maximum (maxParallelForks) // for each test task, such that we are independent of whatever default value is defined in the build itself. "-Dorg.gradle.workers.max=$maxParallelForks",
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Fri Apr 12 10:49:15 GMT 2024 - 13K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
import java.io.Flushable import java.io.IOException import okhttp3.internal.assertThreadHoldsLock import okhttp3.internal.cache.DiskLruCache.Editor import okhttp3.internal.closeQuietly import okhttp3.internal.concurrent.Task import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.deleteContents import okhttp3.internal.deleteIfExists import okhttp3.internal.isCivilized import okhttp3.internal.okHttpName
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0)