- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 462 for dancer (0.13 sec)
-
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} catch (TimeoutException expected) { } finally { latch.countDown(); } } /** * Tests that a canceled future throws a cancellation exception. * * <p>This method checks the cancel, isCancelled, and isDone methods. */ public void testCanceledFutureThrowsCancellation() throws Exception { assertFalse(future.isDone()); assertFalse(future.isCancelled());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} public void testCancelled() throws Exception { TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); assertFalse(task.isDone()); task.cancel(false); assertTrue(task.isDone()); assertTrue(task.isCancelled()); assertFalse(task.wasInterrupted()); assertThrows(CancellationException.class, () -> getDone(task)); verifyThreadWasNotInterrupted();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* next task will wait for any running callable (or pending {@code Future} returned by an * {@code AsyncCallable}) to complete, without interrupting it (and without calling {@code * cancel} on the {@code Future}). So beware: <i>Even if you cancel every preceding {@code * Future} returned by this class, the next task may still have to wait.</i>. * <li>Once an {@code AsyncCallable} returns a {@code Future}, this class considers that task to
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
} return testCases }() const ( EnvTestEtcdBackend = "_MINIO_ETCD_TEST_SERVER" ) func (s *TestSuiteIAM) setUpEtcd(c *check, etcdServer string) { ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout) defer cancel() configCmds := []string{ "etcd", "endpoints=" + etcdServer, "path_prefix=" + mustGetUUID(), } _, err := s.adm.SetConfigKV(ctx, strings.Join(configCmds, " "))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 47.3K bytes - Viewed (0) -
src/main/webapp/js/admin/plugins/form-validator/lang/nl.js
",imageRatioNotAccepted:"De afbeeldingsverhouding wordt niet geaccepteerd",imageTooSmall:"de afbeelding was te klein",imageTooTall:"de afbeelding kan niet langer zijn dan",imageTooWide:"de afbeelding kan niet wijder zijn dan",lengthBadEnd:" karakters",lengthBadStart:"De ingevoerde waarde moet liggen tussen ",lengthTooLongStart:"De ingevoerde waarde is langer dan ",lengthTooShortStart:"De ingevoerde waarde is korter dan ",max:"max",min:"min",notConfirmed:"Invoerwaarden konden niet worden bevestigd",requiredField:"Dit...
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Jan 01 05:12:47 UTC 2018 - 2.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/RealStream.kt
private val http2Stream: Http2Stream, ) : Stream { override val requestBody = http2Stream.getSource().buffer() override val responseBody = http2Stream.getSink().buffer() override fun cancel() { http2Stream.closeLater(ErrorCode.CANCEL) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Dec 31 18:24:52 UTC 2022 - 1.1K bytes - Viewed (0) -
docs/distributed/DECOMMISSION.md
`mc admin decommission cancel` without an argument, lists out any on-going decommission in progress. ``` λ mc admin decommission cancel alias/ ┌─────┬─────────────────────────────────┬──────────────────────────────────┬──────────┐
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 11 14:59:49 UTC 2022 - 8.3K bytes - Viewed (0) -
internal/logger/targets.go
// // e.g. Send the log to a http server type Target interface { String() string Endpoint() string Stats() types.TargetStats Init(ctx context.Context) error IsOnline(ctx context.Context) bool Cancel() Send(ctx context.Context, entry interface{}) error Type() types.TargetType } type targetsList struct { list []Target mu sync.RWMutex } func newTargetsList() *targetsList {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 03 15:44:50 UTC 2024 - 6K bytes - Viewed (0) -
src/main/webapp/WEB-INF/view/admin/storage/admin_storage.jsp
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu May 26 01:48:41 UTC 2022 - 20.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} private fun cancelLater( call: Call, delayMillis: Int, ): CountDownLatch { val latch = CountDownLatch(1) Thread { sleep(delayMillis) if (cancelMode == CANCEL) { call.cancel() } else { threadToCancel!!.interrupt() } latch.countDown() }.apply { start() } return latch } companion object {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.9K bytes - Viewed (0)