Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 470 for clocked (0.04 seconds)

  1. android/guava/src/com/google/common/util/concurrent/SneakyThrows.java

       * fact the static type of {@link Throwable} is occasionally justified even for a method with no
       * {@code throws} clause: Some such methods can in fact throw a checked exception (e.g., by
       * calling code written in Kotlin).) Typically, we want to let a {@link Throwable} from such a
       * method propagate untouched, just as we'd typically let it do for a non-reflective call.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Dec 30 18:44:22 GMT 2024
    - 2.4K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/base/Suppliers.java

        public T get() {
          // A 2-field variant of Double Checked Locking.
          if (!initialized) {
            synchronized (lock) {
              if (!initialized) {
                T t = delegate.get();
                value = t;
                initialized = true;
                return t;
              }
            }
          }
          // This is safe because we checked `initialized`.
          return uncheckedCastNullableTToT(value);
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 31 21:24:28 GMT 2026
    - 16.1K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

        withLock {
          cancel = !source.finished && source.closed && (sink.finished || sink.closed)
          open = isOpen
        }
        if (cancel) {
          // RST this stream to prevent additional data from being sent. This is safe because the input
          // stream is closed (we won't use any further bytes) and the output stream is either finished
          // or closed (so RSTing both streams doesn't cause harm).
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jul 07 18:57:05 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt

       * Returns the name of the server the client requested via the SNI (Server Name Indication)
       * attribute in the TLS handshake. Unlike the rest of the HTTP exchange, this name is sent in
       * cleartext and may be monitored or blocked by a proxy or other middlebox.
       */
      public val handshakeServerNames: List<String>,
      /** A string like `GET` or `POST`. */
      public val method: String,
      /**
       * The request target from the original HTTP request.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Jun 21 20:36:35 GMT 2025
    - 3.2K bytes
    - Click Count (1)
  5. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                }
                throw new RejectedExecutionException();
              }
            };
        SequentialExecutor executor = new SequentialExecutor(delegate);
        ExecutorService blocked = newCachedThreadPool();
        Future<?> first = blocked.submit(() -> executor.execute(Runnables.doNothing()));
        future.get(10, SECONDS);
        assertThrows(RejectedExecutionException.class, () -> executor.execute(Runnables.doNothing()));
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 10.5K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java

      }
    
      @Override
      @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
      public void runWithTimeout(Runnable runnable, long timeoutDuration, TimeUnit timeoutUnit) {
        checkNotNull(runnable);
        checkNotNull(timeoutUnit);
        try {
          runnable.run();
        } catch (Exception e) { // sneaky checked exception
          throw new UncheckedExecutionException(e);
        } catch (Error e) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3.6K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/cache/LoadingCache.java

       * new value.
       *
       * <p>If the cache loader associated with this cache is known not to throw checked exceptions,
       * then prefer {@link #getUnchecked} over this method.
       *
       * @throws ExecutionException if a checked exception was thrown while loading the value. ({@code
       *     ExecutionException} is thrown <a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 03 12:40:22 GMT 2026
    - 8.5K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

          queue.add(submittedTask);
          workerRunningState = QUEUING;
        }
    
        try {
          executor.execute(worker);
        } catch (Throwable t) {
          // Any Exception is either a RuntimeException or sneaky checked exception.
          synchronized (queue) {
            boolean removed =
                (workerRunningState == IDLE || workerRunningState == QUEUING)
                    && queue.removeLastOccurrence(submittedTask);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  9. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/FilePermissionsTask.java

        private final ProjectLayout projectLayout;
    
        /**
         * A pattern set of which files should be checked.
         */
        private final PatternFilterable filesFilter = new PatternSet()
            // we always include all source files, and exclude what should not be checked
            .include("**")
            // exclude sh files that might have the executable bit set
            .exclude("**/*.sh");
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 3.9K bytes
    - Click Count (0)
  10. .github/workflows/stale-issues.yml

              stale-issue-message: > 
                This issue is stale because it has been open for 7 days with no activity.
                It will be closed if no further activity occurs. Thank you.
              close-issue-message: >
                This issue was closed because it has been inactive for 7 days since being marked as stale.
                Please reopen if you'd like to work on this further.
              days-before-pr-stale: 14
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Jan 01 08:09:03 GMT 2026
    - 4.1K bytes
    - Click Count (0)
Back to Top