Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 614 for threads (0.07 sec)

  1. android/guava-tests/test/com/google/common/io/MoreFilesTest.java

          MoreFiles.deleteDirectoryContents(symlink, ALLOW_INSECURE);
          assertEquals(0, MoreFiles.listFiles(dir).size());
        }
      }
    
      /**
       * This test attempts to create a situation in which one thread is constantly changing a file from
       * being a real directory to being a symlink to another directory. It then calls
       * deleteDirectoryContents thousands of times on a directory whose subtree contains the file
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 16:07:00 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

          Request.Builder()
            .url(server.url("/"))
            .build()
        val call = client.newCall(request)
        call.timeout().timeout(250, TimeUnit.MILLISECONDS)
        val response = call.execute()
        Thread.sleep(500)
        assertFailsWith<IOException> {
          response.body.source().readUtf8()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("timeout")
          assertThat(call.isCanceled()).isTrue()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  3. src/archive/tar/reader.go

    //
    // Note that the GNU manual says that numeric values should be encoded in octal
    // format. However, the GNU tar utility itself outputs these values in decimal.
    // As such, this library treats values as being encoded in decimal.
    func readGNUSparseMap1x0(r io.Reader) (sparseDatas, error) {
    	var (
    		cntNewline int64
    		buf        bytes.Buffer
    		blk        block
    	)
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/ForwardingList.java

     * invoke methods, they invoke methods on the {@code ForwardingList}.
     *
     * <p>The {@code standard} methods and any collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Mike Bostock
     * @author Louis Wasserman
     * @since 2.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 15:26:39 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/DispatcherTest.kt

      }
    
      private fun makeSynchronousCall(call: Call): Thread {
        val thread =
          Thread {
            try {
              call.execute()
              throw AssertionError()
            } catch (expected: IOException) {
            }
          }
        thread.start()
        return thread
      }
    
      private fun newRequest(url: String): Request {
        return Request.Builder().url(url).build()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/ForwardingSortedMap.java

     * equality for both keys and values, unlike {@code ForwardingMap}.
     *
     * <p>The {@code standard} methods and the collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Mike Bostock
     * @author Louis Wasserman
     * @since 2.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 15:26:39 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

        public void finalizeReferent() {
          finalizeReferentCalled = true;
        }
      }
    
      /**
       * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we
       * know that the background thread has stopped and released its strong reference.
       */
      private WeakReference<ReferenceQueue<Object>> queueReference;
    
    
      public void testThatFinalizerStops() {
        weaklyReferenceQueue();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/ForwardingBlockingDeque.java

     * invoke methods, they invoke methods on the {@code ForwardingBlockingDeque}.
     *
     * <p>The {@code standard} methods are not guaranteed to be thread-safe, even when all of the
     * methods that they depend on are thread-safe.
     *
     * @author Emily Soldal
     * @since 14.0
     * @deprecated This class has moved to {@code com.google.common.util.concurrent}. Please use {@link
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 13 14:30:51 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/UncheckedExecutionException.java

     * possibly run in another thread.
     *
     * <p>{@code UncheckedExecutionException} is intended as an alternative to {@code
     * ExecutionException} when the exception thrown by a task is an unchecked exception. However, it
     * may also wrap a checked exception in some cases.
     *
     * <p>When wrapping an {@code Error} from another thread, prefer {@link ExecutionError}. When
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Mar 07 17:52:19 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

         * @see java.lang.Runnable#run()
         */
        @Override
        public void run() {
            log(logHelper, LogType.START_THREAD, crawlerContext);
            int threadCheckCount = 0;
            // set urlQueue to thread
            CrawlingParameterUtil.setCrawlerContext(crawlerContext);
            CrawlingParameterUtil.setUrlQueueService(urlQueueService);
            CrawlingParameterUtil.setDataService(dataService);
            try {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:41:37 UTC 2024
    - 15.5K bytes
    - Viewed (0)
Back to top