Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 231 for nwait (0.06 sec)

  1. docs/en/docs/js/termynal.js

                }
    
                else if (type == 'progress') {
                    await this.progress(line);
                    await this._wait(delay);
                }
    
                else {
                    this.container.appendChild(line);
                    await this._wait(delay);
                }
    
                line.removeAttribute(`${this.pfx}-cursor`);
            }
            this.addRestart()
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu May 12 00:06:16 UTC 2022
    - 9.3K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

            executor.execute(wrapper);
          }
          barrier.await(); // release the threads!
          barrier.await(); // wait for them all to complete
          assertEquals(1, task.get().intValue());
          assertEquals(1, counter.get());
        }
        executor.shutdown();
      }
    
      @J2ktIncompatible
      @GwtIncompatible // blocking wait
      public void testToString() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertTrue(listenerLatch.await(5, SECONDS));
        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
      }
    
      public void testListenerCalledOnException() throws Exception {
        throwException = true;
    
        // Start up the task and unblock the latch to finish the task.
        exec.execute(task);
        runLatch.await();
        taskLatch.countDown();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertTrue(listenerLatch.await(5, SECONDS));
        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
      }
    
      public void testListenerCalledOnException() throws Exception {
        throwException = true;
    
        // Start up the task and unblock the latch to finish the task.
        exec.execute(task);
        runLatch.await();
        taskLatch.countDown();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

            };
        Thread runner = new Thread(task);
        runner.start();
        isInterruptibleRegistered.await();
        RuntimeException expected = assertThrows(RuntimeException.class, () -> task.interruptTask());
        assertThat(expected)
            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        // We need to wait for the runner to exit.  It used to be that the runner would get stuck in the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

                })
            .start();
    
        future.cancel(true);
    
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
    
        assertTrue(successLatch.await(200, MILLISECONDS));
        assertTrue(listenerLatch.await(200, MILLISECONDS));
    
        latch.countDown();
    
        exec.shutdown();
        exec.awaitTermination(100, MILLISECONDS);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  7. internal/cachevalue/cache.go

    	// even if updating the value errors out.
    	// Returns the last good value AND the error.
    	ReturnLastGood bool
    
    	// If NoWait is set, Get() will return the last good value,
    	// if TTL has expired but 2x TTL has not yet passed,
    	// but will fetch a new value in the background.
    	NoWait bool
    }
    
    // Cache contains a synchronized value that is considered valid
    // for a specific amount of time.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

                })
            .start();
    
        future.cancel(true);
    
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
    
        assertTrue(successLatch.await(200, MILLISECONDS));
        assertTrue(listenerLatch.await(200, MILLISECONDS));
    
        latch.countDown();
    
        exec.shutdown();
        exec.awaitTermination(100, MILLISECONDS);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/RecordingCallback.kt

        (this as Object).notifyAll()
      }
    
      /**
       * Returns the recorded response triggered by `request`. Throws if the response isn't
       * enqueued before the timeout.
       */
      @Synchronized
      fun await(url: HttpUrl): RecordedResponse {
        val timeoutMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) + TIMEOUT_MILLIS
        while (true) {
          val i = responses.iterator()
          while (i.hasNext()) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  10. compat/maven-embedder/src/test/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListenerTest.java

                });
            }
    
            // start all threads at once
            try {
                startLatch.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    
            // wait for all thread to end
            try {
                endLatch.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5K bytes
    - Viewed (0)
Back to top