Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1021 - 1030 of 2,682 for latch (0.02 seconds)

  1. guava-testlib/src/com/google/common/collect/testing/testers/MapReplaceAllTester.java

                    return values().asList().get(index + 1);
                  });
        } catch (UnsupportedOperationException tolerated) {
        }
        expectUnchanged();
      }
    
      @MapFeature.Require(absent = SUPPORTS_PUT)
      public void testReplaceAll_unsupportedNoOpFunction() {
        try {
          getMap().replaceAll((K k, V v) -> v);
        } catch (UnsupportedOperationException tolerated) {
        }
        expectUnchanged();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Nov 14 23:40:07 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java

          recordedTasks = tasks;
          recordedTimeout = timeout;
          recordedTimeUnit = unit;
          try {
            return tasks.iterator().next().call();
          } catch (Exception e) {
            throw new ExecutionException(e);
          }
        }
    
        @Override
        public <T> List<Future<T>> invokeAll(
            Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  3. src/main/java/jcifs/context/CIFSContextWrapper.java

         *
         * @see jcifs.CIFSContext#get(java.lang.String)
         */
        @Override
        public SmbResource get(final String url) throws CIFSException {
            try {
                return new SmbFile(url, this);
            } catch (final MalformedURLException e) {
                throw new CIFSException("Invalid URL " + url, e);
            }
        }
    
        /**
         *
         * {@inheritDoc}
         *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  4. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/ApplyTest.java

                                    try {
                                        Files.deleteIfExists(path);
                                    } catch (Exception e) {
                                        // Ignore cleanup errors
                                    }
                                });
                    } catch (Exception e) {
                        // Ignore cleanup errors
                    }
                }
            }
        }
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Nov 18 10:39:17 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/cache/LocalCache.java

          result = map;
          success = true;
        } catch (UnsupportedLoadingOperationException e) {
          success = true;
          throw e;
        } catch (InterruptedException e) {
          Thread.currentThread().interrupt();
          throw new ExecutionException(e);
        } catch (RuntimeException e) {
          throw new UncheckedExecutionException(e);
        } catch (Exception e) {
          throw new ExecutionException(e);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 143.5K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/collect/QueuesTest.java

        Future<?> possiblyIgnoredError = threadPool.submit(new Interrupter(currentThread()));
        try {
          Queues.drain(q, ImmutableList.of(), 100, MAX_VALUE, NANOSECONDS);
          fail();
        } catch (InterruptedException expected) {
        }
      }
    
      public void testDrainUninterruptibly_doesNotThrow() throws Exception {
        for (BlockingQueue<Object> q : blockingQueues()) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticator.java

                if (StringUtils.isEmpty(nonce) || !nonce.equals(stateData.getNonce())) {
                    throw new SsoLoginException("could not validate nonce");
                }
            } catch (final SsoLoginException e) {
                throw e;
            } catch (final Exception e) {
                throw new SsoLoginException("could not validate nonce", e);
            }
        }
    
        /**
         * Obtains an access token using a refresh token.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Mar 15 08:03:27 GMT 2026
    - 56.8K bytes
    - Click Count (0)
  8. docs/en/docs/reference/fastapi.md

                - openapi
                - websocket
                - include_router
                - get
                - put
                - post
                - delete
                - options
                - head
                - patch
                - trace
                - on_event
                - middleware
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 701 bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/app/web/api/admin/webconfig/ApiAdminWebconfigAction.java

            body.crudMode = CrudMode.CREATE;
            final WebConfig webConfig = getWebConfig(body).map(entity -> {
                try {
                    webConfigService.store(entity);
                } catch (final Exception e) {
                    logger.warn("Failed to process a request.", e);
                    throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)));
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  10. tensorflow/c/eager/gradients.h

      // Adds this tensor to the list of watched tensors.
      //
      // This is a no-op if the tensor is already being watched either from an
      // earlier call to `GradientTape::Watch` or being an output of an op with
      // watched inputs.
      void Watch(const AbstractTensorHandle*);
      // Records an operation with given inputs and outputs
      // on the tape and marks all its outputs as watched if at
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Sat Oct 12 05:11:17 GMT 2024
    - 6.9K bytes
    - Click Count (0)
Back to Top