- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for nanotime1 (2.98 sec)
-
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
redQueue.execute("task one", 100.µs) { log += "one:run@${taskFaker.nanoTime} parallel=${taskFaker.isParallel}" } redQueue.execute("task two", 100.µs) { log += "two:run@${taskFaker.nanoTime} parallel=${taskFaker.isParallel}" } redQueue.execute("task three", 100.µs) { log += "three:run@${taskFaker.nanoTime} parallel=${taskFaker.isParallel}" } taskFaker.advanceUntil(0.µs)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
unit: TimeUnit, ): T? { taskRunner.lock.withLock { val waitUntil = nanoTime + unit.toNanos(timeout) while (true) { val result = poll() if (result != null) return result if (nanoTime >= waitUntil) return null val editCountBefore = editCount yieldUntil { nanoTime >= waitUntil || editCount > editCountBefore } } } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
@SuppressWarnings("removal") // b/260137033 public static void awaitDone(Future<?> future) { if (future.isDone()) { return; } long timeoutSeconds = timeoutSeconds(); long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); do { System.runFinalization(); if (future.isDone()) { return; } System.gc(); try { future.get(1L, SECONDS);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
if (profileTests) runTestProfiled(); else super.runTest(); } protected void runTestProfiled() throws Throwable { long t0 = System.nanoTime(); try { super.runTest(); } finally { long elapsedMillis = (System.nanoTime() - t0) / (1000L * 1000L); if (elapsedMillis >= profileThreshold) System.out.printf("%n%s: %d%n", toString(), elapsedMillis); } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.7K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt
class LoggingEventListener private constructor( private val logger: HttpLoggingInterceptor.Logger, ) : EventListener() { private var startNs: Long = 0 override fun callStart(call: Call) { startNs = System.nanoTime() logWithTime("callStart: ${call.request()}") } override fun proxySelectStart( call: Call, url: HttpUrl, ) { logWithTime("proxySelectStart: $url") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 11:07:32 GMT 2024 - 5.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
@SuppressWarnings("removal") // b/260137033 public static void awaitDone(Future<?> future) { if (future.isDone()) { return; } long timeoutSeconds = timeoutSeconds(); long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); do { System.runFinalization(); if (future.isDone()) { return; } System.gc(); try { future.get(1L, SECONDS);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(pool.connectionCount()).isEqualTo(1) } @Test fun connectionPreWarmingHttp2() { taskFaker.advanceUntil(System.nanoTime()) val expireSooner = taskFaker.nanoTime + 1_000_000_000_000 val expireLater = taskFaker.nanoTime + 2_000_000_000_000 routePlanner.autoGeneratePlans = true val address = routePlanner.address val pool = routePlanner.pool
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.sendFrame().ping(true, Http2Connection.AWAIT_PING, 5) peer.play() // Play it back. val connection = connect(peer) val pingAtNanos = System.nanoTime() connection.writePingAndAwaitPong() val elapsedNanos = System.nanoTime() - pingAtNanos assertThat(elapsedNanos).isGreaterThan(0L) assertThat(elapsedNanos).isLessThan(TimeUnit.SECONDS.toNanos(1))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
Int.MAX_VALUE, // keepAliveTime: 60L, TimeUnit.SECONDS, SynchronousQueue(), threadFactory, ) override fun nanoTime() = System.nanoTime() override fun coordinatorNotify(taskRunner: TaskRunner) { taskRunner.condition.signal() } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
Preconditions.checkNotNull(buffer); /* * This code performs one System.nanoTime() more than necessary, and in return, the time to * execute Queue#drainTo is not added *on top* of waiting for the timeout (which could make * the timeout arbitrarily inaccurate, given a queue that is slow to drain). */ long deadline = System.nanoTime() + unit.toNanos(timeout); int added = 0; while (added < numElements) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 16K bytes - Viewed (0)