Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for Thread (0.05 sec)

  1. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        CountDownLatch doneSignal = new CountDownLatch(1);
        Thread thread =
            new Thread(
                () -> {
                  try {
                    cache.get(key, loader);
                  } catch (UncheckedExecutionException | ExecutionException e) {
                    doneSignal.countDown();
                  }
                });
        thread.start();
    
        boolean done = doneSignal.await(1, SECONDS);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        CountDownLatch doneSignal = new CountDownLatch(1);
        Thread thread =
            new Thread(
                () -> {
                  try {
                    cache.get(key, loader);
                  } catch (UncheckedExecutionException | ExecutionException e) {
                    doneSignal.countDown();
                  }
                });
        thread.start();
    
        boolean done = doneSignal.await(1, SECONDS);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/CallTest.kt

        call: Call,
        delay: Long,
      ): Thread {
        val thread =
          object : Thread("canceler") {
            override fun run() {
              try {
                sleep(delay)
              } catch (e: InterruptedException) {
                throw AssertionError()
              }
              call.cancel()
            }
          }
        thread.start()
        return thread
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/cache/LocalCache.java

        public void clear() {
          ReferenceEntry<K, V> e = head.getNextInWriteQueue();
          while (e != head) {
            ReferenceEntry<K, V> next = e.getNextInWriteQueue();
            nullifyWriteOrder(e);
            e = next;
          }
    
          head.setNextInWriteQueue(head);
          head.setPreviousInWriteQueue(head);
        }
    
        @Override
        public Iterator<ReferenceEntry<K, V>> iterator() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Maps.java

        return Synchronized.biMap(bimap, null);
      }
    
      /**
       * Returns an unmodifiable view of the specified bimap. This method allows modules to provide
       * users with "read-only" access to internal bimaps. Query operations on the returned bimap "read
       * through" to the specified bimap, and attempts to modify the returned map, whether direct or via
       * its collection views, result in an {@code UnsupportedOperationException}.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 161.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/Maps.java

        return Synchronized.biMap(bimap, null);
      }
    
      /**
       * Returns an unmodifiable view of the specified bimap. This method allows modules to provide
       * users with "read-only" access to internal bimaps. Query operations on the returned bimap "read
       * through" to the specified bimap, and attempts to modify the returned map, whether direct or via
       * its collection views, result in an {@code UnsupportedOperationException}.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 167.4K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        val inputStream = response.body.byteStream()
        assertThat(inputStream.read().toChar()).isEqualTo('A')
        call.cancel()
        assertFailsWith<IOException> {
          // Reading 'B' may succeed if it's buffered.
          inputStream.read()
    
          // But 'C' shouldn't be buffered (the response is throttled) and this should fail.
          inputStream.read()
        }
        inputStream.close()
      }
    
      @Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/mylasta/action/FessLabels.java

        public static final String LABELS_MAX_ACCESS_COUNT = "{labels.maxAccessCount}";
    
        /** The key of the message: Name */
        public static final String LABELS_NAME = "{labels.name}";
    
        /** The key of the message: Num of Thread */
        public static final String LABELS_NUM_OF_THREAD = "{labels.numOfThread}";
    
        /** The key of the message: Duplicate Name */
        public static final String LABELS_DUPLICATE_HOST_NAME = "{labels.duplicateHostName}";
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Mar 22 11:58:34 UTC 2024
    - 146.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/mylasta/action/FessMessages.java

        /** The key of the message: Unauthorized request. */
        public static final String ERRORS_unauthorized_request = "{errors.unauthorized_request}";
    
        /** The key of the message: Failed to print thread dump. */
        public static final String ERRORS_failed_to_print_thread_dump = "{errors.failed_to_print_thread_dump}";
    
        /** The key of the message: {0} is not supported. */
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/CacheTest.kt

        // A conditional cache hit updates the cache.
        Thread.sleep(500) // Make sure t0 and t1 are distinct.
        val t1 = System.currentTimeMillis()
        val response2 = get(server.url("/a"))
        assertThat(response2.code).isEqualTo(HttpURLConnection.HTTP_OK)
        assertThat(response2.body.string()).isEqualTo("A")
        assertThat(response2.header("Allow")).isEqualTo("GET, HEAD")
        val updatedTimestamp = response2.receivedResponseAtMillis
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 108.6K bytes
    - Viewed (0)
Back to top