Search Options

Results per page
Sort
Preferred Languages
Advance

Results 681 - 690 of 2,167 for latch (0.06 sec)

  1. guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

        SettableFuture<String> future = SettableFuture.create();
        Thread.currentThread().interrupt();
        try {
          getChecked(future, TwoArgConstructorException.class);
          fail();
        } catch (TwoArgConstructorException expected) {
          assertThat(expected).hasCauseThat().isInstanceOf(InterruptedException.class);
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  2. common-protos/k8s.io/api/flowcontrol/v1beta1/generated.proto

      // `distinguisherMethod` defines how to compute the flow distinguisher for requests that match this schema.
      // `nil` specifies that the distinguisher is disabled and thus will always be the empty string.
      // +optional
      optional FlowDistinguisherMethod distinguisherMethod = 3;
    
      // `rules` describes which requests will match this flow schema. This FlowSchema matches a request if and only if
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/primitives/UnsignedBytesTest.java

        try {
          UnsignedBytes.parseUnsignedByte(value);
          fail();
        } catch (NumberFormatException expected) {
        }
      }
    
      private static void assertParseFails(String value, int radix) {
        try {
          UnsignedBytes.parseUnsignedByte(value, radix);
          fail();
        } catch (NumberFormatException expected) {
        }
      }
    
      public void testParseUnsignedByte() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        assertThat(future.isCancelled()).isFalse();
    
        try {
          getDone(future);
          fail();
        } catch (ExecutionException e) {
          assertThat(e.getCause()).isSameInstanceAs(expectedException);
        }
    
        try {
          getDoneFromTimeoutOverload(future);
          fail();
        } catch (ExecutionException e) {
          assertThat(e).hasCauseThat().isSameInstanceAs(expectedException);
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/platform/android/AndroidCertificateChainCleaner.kt

        hostname: String,
      ): List<Certificate> {
        val certificates = (chain as List<X509Certificate>).toTypedArray()
        try {
          return x509TrustManagerExtensions.checkServerTrusted(certificates, "RSA", hostname)
        } catch (ce: CertificateException) {
          throw SSLPeerUnverifiedException(ce.message).apply { initCause(ce) }
        }
      }
    
      override fun equals(other: Any?): Boolean =
        other is AndroidCertificateChainCleaner &&
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/ds/AbstractDataStoreTest.java

                    try {
                        return groovyShell.evaluate(template);
                    } catch (final JobProcessingException e) {
                        throw e;
                    } catch (final Exception e) {
                        return null;
                    } finally {
                        final GroovyClassLoader loader = groovyShell.getClassLoader();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/core/security/MessageDigestUtil.java

         */
        public static MessageDigest getInstance(final String algorithm) {
            assertArgumentNotEmpty("algorithm", algorithm);
    
            try {
                return MessageDigest.getInstance(algorithm);
            } catch (final NoSuchAlgorithmException e) {
                throw new NoSuchAlgorithmRuntimeException(e);
            }
        }
    
        /**
         * 指定されたアルゴリズムでテキストをハッシュ化して文字列にします。
         *
         * @param algorithm
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/math/LongMathTest.java

          boolean isPowerOf2 = LongMath.isPowerOfTwo(x);
          try {
            assertEquals(x, 1L << LongMath.log2(x, UNNECESSARY));
            assertTrue(isPowerOf2);
          } catch (ArithmeticException e) {
            assertFalse(isPowerOf2);
          }
        }
      }
    
      @GwtIncompatible // TODO
      public void testLog10ZeroAlwaysThrows() {
        for (RoundingMode mode : ALL_ROUNDING_MODES) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 15:00:32 UTC 2024
    - 30.6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

                try {
                    join();
                } catch (final InterruptedException e) {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Interrupted.", e);
                    }
                }
            }
    
            public void awaitTermination(final long mills) {
                try {
                    join(mills);
                } catch (final InterruptedException e) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/dict/synonym/AdminDictSynonymAction.java

            return synonymService.getSynonymFile(form.dictId).map(file -> {
                try (InputStream inputStream = form.synonymFile.getInputStream()) {
                    file.update(inputStream);
                } catch (final IOException e) {
                    logger.warn("Failed to process a request.", e);
                    throwValidationError(messages -> messages.addErrorsFailedToUploadSynonymFile(GLOBAL),
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 19.5K bytes
    - Viewed (0)
Back to top