Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 55 for thread (0.21 sec)

  1. 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)
  2. 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)
  3. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

      if (assertionsEnabled && !this.isHeldByCurrentThread) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
      }
    }
    
    @Suppress("NOTHING_TO_INLINE")
    internal inline fun Any.assertThreadHoldsLock() {
      if (assertionsEnabled && !Thread.holdsLock(this)) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
      }
    }
    
    @Suppress("NOTHING_TO_INLINE")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 09 12:33:05 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

            .connectionPool(ConnectionPool(connectionListener = connectionListener))
        }
    
      private fun loomThreadFactory(): ThreadFactory {
        val ofVirtual = Thread::class.java.getMethod("ofVirtual").invoke(null)
    
        return Class.forName("java.lang.Thread\$Builder")
          .getMethod("factory")
          .invoke(ofVirtual) as ThreadFactory
      }
    
      private fun isLoom(): Boolean {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. docs/en/docs/how-to/sql-databases-peewee.md

        This was useful in older frameworks designed to have one single thread per request, no more, no less.
    
        Using this, each request would have its own database connection/session, which is the actual final goal.
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Tue Jan 16 13:23:25 GMT 2024
    - 23.6K bytes
    - Viewed (1)
  8. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

              sink.writeUtf8("abc")
              sink.flush()
              Thread.sleep(sleepMillis.toLong())
              sink.writeUtf8("def")
            } catch (e: InterruptedException) {
              throw InterruptedIOException()
            }
          }
        }
      }
    
      companion object {
        /** A large response body. Smaller bodies might successfully read after the socket is closed!  */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top