- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 483 for released (0.17 sec)
-
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AggregateFutureState.java
abstract class AggregateFutureState<OutputT extends @Nullable Object> extends AbstractFuture.TrustedFuture<OutputT> { // Lazily initialized the first time we see an exception; not released until all the input futures // & this future completes. Released when the future releases the reference to the running state private @Nullable Set<Throwable> seenExceptions = null; private int remaining; AggregateFutureState(int remainingFutures) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 08 20:30:27 GMT 2022 - 1.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTest.java
public void testNoNewApis() throws Exception { assertWithMessage( "Do not add new methods to ListenableFuture. Its API needs to continue to match the" + " version we released in a separate artifact com.google.guava:listenablefuture.") .that(ListenableFuture.class.getDeclaredMethods()) .asList() .containsExactly(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Jun 15 19:48:16 GMT 2023 - 1.7K bytes - Viewed (0) -
cmd/update-notifier.go
return "" } // Compute friendly duration string to indicate time // difference between newer and current release. t := time.Time{} newerThan := humanize.RelTime(t, t.Add(older), "before the latest release", "") if globalServerCtxt.JSON { return fmt.Sprintf("You are running an older version of MinIO released %s, update: %s", newerThan, downloadURL) } // Return the nicely colored and formatted update message.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 3.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTest.java
public void testNoNewApis() throws Exception { assertWithMessage( "Do not add new methods to ListenableFuture. Its API needs to continue to match the" + " version we released in a separate artifact com.google.guava:listenablefuture.") .that(ListenableFuture.class.getDeclaredMethods()) .asList() .containsExactly(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Jun 15 19:48:16 GMT 2023 - 1.7K bytes - Viewed (0) -
cmd/namespace-lock.go
return LockContext{ctx: ctx, cancel: func() {}}, OperationTimedOut{} } timeout.LogSuccess(UTCNow().Sub(start)) return LockContext{ctx: newCtx, cancel: cancel}, nil } // Unlock - block until write lock is released. func (di *distLockInstance) Unlock(lc LockContext) { if lc.cancel != nil { lc.cancel() } di.rwMutex.Unlock(lc.ctx) } // RLock - block until read lock is taken or timeout has occurred.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Connection.kt
* one or more streams, and then released. An allocated connection won't be stolen by other calls * while a redirect or authorization challenge is being handled. * * When the maximum concurrent streams limit is reduced, some allocations will be rescinded. * Attempting to create new streams on these allocations will fail. * * Note that an allocation may be released before its stream is completed. This is intended to make
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.3K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* * @author Sven Mawson * @author Nishant Thakkar * @since 1.0 */ /* * Some of the annotations below were added after we released our separate * com.google.guava:listenablefuture:1.0 artifact. (For more on that artifact, see * https://github.com/google/guava/releases/tag/v27.0) This means that the copy of ListenableFuture * in com.google.guava:guava differs from the "frozen" copy in the listenablefuture artifact. This
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractAcceptedApiChangesMaintenanceTaskIntegrationTest.kt
*/ protected fun setupPluginRequirements() { projectDir.resolve("version.txt").writeText("9999999.0") // All released versions should be lower than this projectDir.resolve("released-versions.json").writeText( """ { "latestReleaseSnapshot": { "version": "7.6-20220831090819+0000",
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Mon Nov 28 21:09:42 GMT 2022 - 5.6K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
// fmt.Println("2nd read lock acquired, waiting...") go func() { time.Sleep(2 * time.Second) lrwm.RUnlock() // fmt.Println("1st read lock released, waiting...") }() go func() { time.Sleep(3 * time.Second) lrwm.RUnlock() // fmt.Println("2nd read lock released, waiting...") }() // fmt.Println("Trying to acquire write lock, waiting...") locked = lrwm.GetLock(ctx, "", "", duration) if locked {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 7.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* * @author Sven Mawson * @author Nishant Thakkar * @since 1.0 */ /* * Some of the annotations below were added after we released our separate * com.google.guava:listenablefuture:1.0 artifact. (For more on that artifact, see * https://github.com/google/guava/releases/tag/v27.0) This means that the copy of ListenableFuture * in com.google.guava:guava differs from the "frozen" copy in the listenablefuture artifact. This
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0)