Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 731 for Threads (0.08 sec)

  1. android/guava-tests/test/com/google/common/collect/MapMakerTest.java

      public void testNullParameters() throws Exception {
        NullPointerTester tester = new NullPointerTester();
        tester.testAllPublicInstanceMethods(new MapMaker());
      }
    
      @GwtIncompatible // threads
      static final class DelayingIdentityLoader<T> implements Function<T, T> {
        private final CountDownLatch delayLatch;
    
        DelayingIdentityLoader(CountDownLatch delayLatch) {
          this.delayLatch = delayLatch;
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

            .connectionPool(ConnectionPool(connectionListener = connectionListener))
        }
    
      private fun loomThreadFactory(): ThreadFactory {
        val ofVirtual = Thread::class.java.getMethod("ofVirtual").invoke(null)
    
        return Class
          .forName("java.lang.Thread\$Builder")
          .getMethod("factory")
          .invoke(ofVirtual) as ThreadFactory
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/TreeBasedTable.java

     * {@link Map} specified in the {@link Table} interface.
     *
     * <p>Note that this implementation is not synchronized. If multiple threads access this table
     * concurrently and one of the threads modifies the table, it must be synchronized externally.
     *
     * <p>See the Guava User Guide article on <a href=
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 18 15:05:43 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt

       * the list otherwise we'll be left in a bad state. If the thread was interrupted prior to this
       * operation, it will be re-interrupted after the list is read.
       */
      private fun readTheListUninterruptibly() {
        var interrupted = false
        try {
          while (true) {
            try {
              readTheList()
              return
            } catch (_: InterruptedIOException) {
              Thread.interrupted() // Temporarily clear the interrupted state.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  5. docs/changelogs/changelog_1x.md

     * Support asynchronous disconnects by breaking the socket only. This should
       prevent flakiness from multiple threads concurrently accessing a stream.
    
    ## Version 1.5.3
    
    _2014-03-29_
    
     * Fix bug where the Content-Length header was not always dropped when
       following a redirect from a POST to a GET.
     * Implement basic support for `Thread.interrupt()`. OkHttp now checks
       for an interruption before doing a blocking call. If it is interrupted,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb/NtlmPasswordAuthenticatorTimingAttackTest.java

                        }
                    });
                }
    
                executor.shutdown();
                assertTrue(executor.awaitTermination(30, TimeUnit.SECONDS), "All threads should complete within timeout");
    
                // Analyze timing consistency across threads
                if (!timings.isEmpty()) {
                    double avgTime = timings.stream().mapToLong(Long::longValue).average().orElse(0.0);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 11.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

                });
        assertFalse(task.isDone());
        Thread thread =
            new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
                      task.run();
                    } finally {
                      exitLatch.countDown();
                    }
                  }
                });
        thread.start();
        enterLatch.await();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java

      /**
       * Returns an exception handler that exits the system. This is particularly useful for the main
       * thread, which may start up other, non-daemon threads, but fail to fully initialize the
       * application successfully.
       *
       * <p>Example usage:
       *
       * <pre>
       * public static void main(String[] args) {
       *   Thread.currentThread().setUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit());
       *   ...
       * </pre>
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Feb 10 21:03:40 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  9. src/main/resources/fess_message_pt_BR.properties

    errors.could_not_delete_logged_in_user=Não é possível excluir o usuário logado.
    errors.unauthorized_request=Solicitação não autorizada.
    errors.failed_to_print_thread_dump=Não foi possível imprimir o despejo de threads.
    errors.file_is_not_supported={0} não é suportado.
    errors.plugin_file_is_not_found={0} não encontrado.
    errors.failed_to_install_plugin=Não foi possível instalar {0}.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 10 04:56:21 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
    
        CountDownLatch successLatch = new CountDownLatch(1);
    
        // Run cancellation in a separate thread as an extra thread-safety test.
        new Thread(
                () -> {
                  assertThrows(CancellationException.class, future::get);
                  successLatch.countDown();
                })
            .start();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 6.1K bytes
    - Viewed (0)
Back to top