Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 79 for countdown (0.05 sec)

  1. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                        executor.execute(new ResolveTask(
                                classLoader, latch, artifact, session, node.getRemoteRepositories(), result));
                    } else {
                        latch.countDown();
                    }
                }
                try {
                    latch.await();
                } catch (InterruptedException e) {
                    result.addErrorArtifactException(
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 24.8K bytes
    - Viewed (0)
  2. build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java

                        ps.println(line);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    latch.countDown();
                }
            }).start();
            return os;
        }
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Aug 19 15:07:24 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

          return newTask.latch
        }
      }
    
      private class AwaitIdleTask : Task("$okHttpName awaitIdle", cancelable = false) {
        val latch = CountDownLatch(1)
    
        override fun runOnce(): Long {
          latch.countDown()
          return -1L
        }
      }
    
      /** Adds [task] to run in [delayNanos]. Returns true if the coordinator is impacted. */
      internal fun scheduleAndDecide(
        task: Task,
        delayNanos: Long,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        clientListener.assertOpen()
        clientListener.assertFailure(
          SocketTimeoutException::class.java,
          "sent ping but didn't receive pong within 500ms (after 0 successful ping/pongs)",
        )
        latch.countDown()
        val elapsedUntilFailure = System.nanoTime() - openAtNanos
        assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedUntilFailure).toDouble())
          .isCloseTo(1000.0, 250.0)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

        val latch = CountDownLatch(1)
        Thread {
          sleep(delayMillis)
          if (cancelMode == CANCEL) {
            call.cancel()
          } else {
            threadToCancel!!.interrupt()
          }
          latch.countDown()
        }.apply { start() }
        return latch
      }
    
      companion object {
        // The size of the socket buffers in bytes.
        private const val SOCKET_BUFFER_SIZE = 256 * 1024
      }
    }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

            .addNetworkInterceptor(
              Interceptor { chain ->
                try {
                  chain.proceed(chain.request())
                } finally {
                  firstConnectLatch.countDown()
                }
              },
            )
            .build()
    
        // Set up a same-connection retry.
        serverIpv4.enqueue(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                  }
                });
        future.get(10, SECONDS);
        assertThrows(RejectedExecutionException.class, () -> executor.execute(Runnables.doNothing()));
        latch.countDown();
        ExecutionException expected =
            assertThrows(ExecutionException.class, () -> first.get(10, SECONDS));
        assertThat(expected).hasCauseThat().isInstanceOf(RejectedExecutionException.class);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

            suggester.indexer().indexFromDocument(() -> reader, 1000, 100).then(response -> {
                numObInputDoc.set(response.getNumberOfInputDocs());
                latch.countDown();
            }).error(t -> {
                t.printStackTrace();
                latch.countDown();
                fail();
            });
            latch.await();
            assertEquals(num, numObInputDoc.get());
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 37K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ScheduledThreadPoolExecutor delegate =
            new ScheduledThreadPoolExecutor(1) {
              @Override
              protected void afterExecute(Runnable r, Throwable t) {
                completed.countDown();
              }
            };
        ListeningScheduledExecutorService service = listeningDecorator(delegate);
        ListenableFuture<Integer> future = service.schedule(Callables.returning(42), 1, MILLISECONDS);
    
        /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/EventListenerTest.kt

            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              completionLatch.countDown()
            }
    
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
              response.close()
              completionLatch.countDown()
            }
          }
        call.enqueue(callback)
        completionLatch.await()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
Back to top