Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newVirtualThreadPerTaskExecutor (0.44 sec)

  1. container-tests/src/test/java/okhttp3/containers/BasicLoomTest.kt

        client =
          OkHttpClient.Builder()
            .trustMockServer()
            .dispatcher(Dispatcher(newVirtualThreadPerTaskExecutor()))
            .build()
    
        executor = newVirtualThreadPerTaskExecutor()
    
        // Capture non-deterministic but probable sysout warnings of pinned threads
        // https://docs.oracle.com/en/java/javase/21/core/virtual-threads.html
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 06 11:15:46 GMT 2024
    - 3.7K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/LoomTest.kt

        this.server = server
    
        client =
          clientTestRule.newClientBuilder()
            .dispatcher(Dispatcher(newVirtualThreadPerTaskExecutor()))
            .build()
      }
    
      private fun newVirtualThreadPerTaskExecutor(): ExecutorService {
        return Executors::class.java.getMethod("newVirtualThreadPerTaskExecutor").invoke(null) as ExecutorService
      }
    
      @Test
      fun testRequest() {
        server.enqueue(MockResponse())
    
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2K bytes
    - Viewed (0)
Back to top