- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for thread (0.17 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
/** * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until * the already-requested ones are in service, otherwise we might create more threads than we need. * * We use [executeCallCount] and [runCallCount] to defend against starting more threads than we
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) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this") } } @Suppress("NOTHING_TO_INLINE") internal inline fun Any.assertThreadDoesntHoldLock() { if (assertionsEnabled && taskRunner.lock.isHeldByCurrentThread) { throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this") } }
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) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} /** Receive frames until there are no more. Invoked only by the reader thread. */ @Throws(IOException::class) fun loopReader(response: Response) { try { listener.onOpen(this@RealWebSocket, response) while (receivedCloseCode == -1) { // This method call results in one or more onRead* methods being called on this thread. reader!!.processNextFrame() } } catch (e: Exception) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(realTaskRunner.activeQueues()).isNotEmpty() Thread.sleep(100) val threads = arrayOfNulls<Thread>(Thread.activeCount() * 2) Thread.enumerate(threads) for (t in threads) { if (t != null && t.name == "OkHttp TaskRunner") { t.interrupt() } } Thread.sleep(100) assertThat(realTaskRunner.activeQueues()).isEmpty() }
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/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* until we send the frame that acknowledges this new size. * * Since we can't ACK settings on the current reader thread (the reader thread can't write) we * execute all peer settings logic on the writer thread. This relies on the fact that the * writer task queue won't reorder tasks; otherwise settings could be applied in the opposite * order than received. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
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()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
} @JvmStatic fun threadFactory(name: String): ThreadFactory { return object : ThreadFactory { private var nextId = 1 override fun newThread(runnable: Runnable): Thread { return Thread(runnable, "$name-${nextId++}") } } } } fun getEnv(name: String) = System.getenv(name) val SYSTEM_FILE_SYSTEM = FileSystem.SYSTEM
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocksProxy.kt
fun play() { serverSocket = ServerSocket(0) executor.execute { val threadName = "SocksProxy ${serverSocket!!.localPort}" Thread.currentThread().name = threadName try { while (true) { val socket = serverSocket!!.accept() connectionCount.incrementAndGet() service(socket) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
*/ internal var interceptorScopedExchange: Exchange? = null private set // These properties are guarded by [lock]. They are typically only accessed by the thread executing // the call, but they may be accessed by other threads for duplex requests. /** True if this call still has a request body open. */ private var requestBodyOpen = false /** True if this call still has a response body open. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
// Enqueueing the red task starts a thread because the head of the queue changed. redQueue.execute("red task") { log += "red:starting@${taskFaker.nanoTime}" taskFaker.sleep(100.µs) log += "red:finishing@${taskFaker.nanoTime}" } assertThat(taskFaker.executeCallCount).isEqualTo(1) // Enqueueing the blue task doesn't start a thread because the red one is still starting.
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)