- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 289 for startIdx (0.07 sec)
-
docs/batch-jobs/README.md
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 06 06:00:43 UTC 2022 - 4.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
public Boolean call() { return blockingCallable.isRunning(); } }, directExecutor()); // Wait for the first task to be started in the background. It will block until we explicitly // stop it. blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.7K bytes - Viewed (0) -
internal/dsync/dsync_test.go
func TestThreeSimultaneousLocksForSameResource(t *testing.T) { dm1st := NewDRWMutex(ds, "aap") dm2nd := NewDRWMutex(ds, "aap") dm3rd := NewDRWMutex(ds, "aap") dm1st.Lock(id, source) started := time.Now() var expect time.Duration // Release lock after 10 seconds go func() { // TOTAL time.Sleep(2 * testDrwMutexAcquireTimeout) // fmt.Println("Unlocking dm1")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 14:35:19 UTC 2024 - 11.1K bytes - Viewed (0) -
docs/sts/etcd.md
# etcd V3 Quickstart Guide [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) etcd is a distributed key value store that provides a reliable way to store data across a cluster of machines. ## Get started ### 1. Prerequisites - Docker 18.03 or above, refer here for [installation](https://docs.docker.com/install/). ### 2. Start etcd
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 3.4K bytes - Viewed (0) -
docs/ru/docs/tutorial/first-steps.md
```console $ uvicorn main:app --reload <span style="color: green;">INFO</span>: Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit) <span style="color: green;">INFO</span>: Started reloader process [28720] <span style="color: green;">INFO</span>: Started server process [28722] <span style="color: green;">INFO</span>: Waiting for application startup. <span style="color: green;">INFO</span>: Application startup complete. ```
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 13.1K bytes - Viewed (0) -
README.md
> For a comprehensive overview, please visit the [official Gradle project homepage](https://gradle.org). --- ### 🚀 **Getting Started** Starting with Gradle is easy with these essential resources. Follow these to install Gradle, set up initial projects, and explore supported platforms:
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Fri Nov 01 05:30:25 UTC 2024 - 8K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/project/ProjectUtils.java
import org.codehaus.plexus.component.repository.exception.ComponentLookupException; import org.eclipse.aether.RepositorySystemSession; // This class needs to stick around because it was exposed the remote resources plugin started using it instead of // getting the repositories from the project. /** * ProjectUtils */ @Deprecated public final class ProjectUtils { private ProjectUtils() {}
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.8K bytes - Viewed (0) -
architecture/networking/controllers.md
When a filter changes and includes/removes new objects, those are automatically handled. * Proper syncing and shutdown logic. Checking for when an informer has fully started can be quite tricky; `kclient` automatically handles it. Under the `kclient` package, `clienttest` also provides similar interfaces meant for writing unit tests.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Feb 09 17:41:25 UTC 2024 - 4.9K bytes - Viewed (0) -
internal/grid/grid_test.go
started := time.Now() dl, _ := ctx.Deadline() if testing.Verbose() { fmt.Println(GetCaller(ctx).Name, "Server deadline:", time.Until(dl)) } <-ctx.Done() serverCanceled <- time.Since(started) if testing.Verbose() { fmt.Println(GetCaller(ctx).Name, "Server Context canceled with", ctx.Err(), "after", time.Since(started)) } return nil },
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 36.4K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// Copy write locks to stack array copy(locks, dm.writeLocks) } // Tolerance is not set, defaults to half of the locker clients. tolerance := len(restClnts) / 2 isReadLock := false started := time.Now() // Do async unlocking. // This means unlock will no longer block on the network or missing quorum. go func() { ctx, done := context.WithTimeout(ctx, drwMutexUnlockCallTimeout) defer done()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0)