Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 608 for thead (0.05 seconds)

  2. github.com/apache/maven

    impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/BuildThreadFactory.java 

    public class BuildThreadFactory implements ThreadFactory {
    private final AtomicInteger id = new AtomicInteger();

    private static final String PREFIX = "BuilderThread";

    @Override
    public Thread newThread(Runnable r) {
        return new Thread(r, String.format("%s-%d", PREFIX, id.getAndIncrement()));
    }
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 1.4K bytes
    - Click Count (0)
  3. github.com/square/okhttp

    okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt 

      }

  @JvmStatic
  fun threadFactory(name: String): ThreadFactory =
    object : ThreadFactory {
      private var nextId = 1

      override fun newThread(runnable: Runnable): Thread = Thread(runnable, "$name-${nextId++}")
    }
}

fun getEnv(name: String) = System.getenv(name)

val SYSTEM_FILE_SYSTEM = FileSystem.SYSTEM
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  4. github.com/square/okhttp

    okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt 

        call: Call,
    delay: Long,
  ): Thread {
    val thread =
      object : Thread("canceler") {
        override fun run() {
          try {
            sleep(delay)
          } catch (e: InterruptedException) {
            throw AssertionError()
          }
          call.cancel()
        }
      }
    thread.start()
    return thread
  }
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 147.4K bytes
    - Click Count (0)
  5. github.com/google/guava

    guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java 

        @Override
    public boolean offer(E o) {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.offer(o);
    }

    @Override
    public @Nullable E poll() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.poll();
    }

    @Override
    public E remove() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.remove();
    }

    @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  6. github.com/google/guava

    android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java 

              @Override
          public Thread newThread(Runnable r) {
            Thread thread = new Thread(r);
            thread.setName(THREAD_NAME);
            thread.setPriority(THREAD_PRIORITY);
            thread.setDaemon(THREAD_DAEMON);
            thread.setUncaughtExceptionHandler(UNCAUGHT_EXCEPTION_HANDLER);
            return thread;
          }
        };

    Thread thread =
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 7.6K bytes
    - Click Count (0)
  7. github.com/square/okhttp

    okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt 

        assertThat(c1.noNewExchanges).isTrue()
  }

  @Test fun interruptStopsThread() {
    val taskRunnerThreads = mutableListOf<Thread>()
    val taskRunner =
      TaskRunner(
        RealBackend { runnable ->
          Thread(runnable, "interruptStopsThread TaskRunner")
            .also { taskRunnerThreads += it }
        },
      )

    val pool =
      factory.newConnectionPool(
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  8. github.com/square/okhttp

    okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt 

          takeEvent()
    }
  }

  private fun logEvent(e: ConnectionEvent) {
    if (e.connection != null) {
      assertThat(Thread.holdsLock(e.connection), "Called with lock $${e.connection}")
        .isFalse()
    }
    for (lock in forbiddenLocks) {
      assertThat(Thread.holdsLock(lock), "Called with lock $lock")
        .isFalse()
    }

    if (enforceOrder) {
      checkForStartEvent(e)
    }
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri May 30 21:28:20 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  9. github.com/tiangolo/fastapi

    docs_src/custom_response/tutorial002_py39.py 

    from fastapi.responses import HTMLResponse

app = FastAPI()


@app.get("/items/", response_class=HTMLResponse)
async def read_items():
    return """
    <html>
        <head>
            <title>Some HTML in here</title>
        </head>
        <body>
            <h1>Look ma! HTML!</h1>
        </body>
    </html>
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 352 bytes
    - Click Count (0)
  10. github.com/google/guava

    android/guava-tests/test/com/google/common/collect/SynchronizedTableTest.java 

        @Override
    public String toString() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.toString();
    }

    @Override
    public boolean equals(@Nullable Object o) {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.equals(o);
    }

    @Override
    public int hashCode() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.hashCode();
    }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  11. github.com/tiangolo/fastapi

    docs_src/custom_response/tutorial003_py39.py 

    from fastapi import FastAPI
from fastapi.responses import HTMLResponse

app = FastAPI()


@app.get("/items/")
async def read_items():
    html_content = """
    <html>
        <head>
            <title>Some HTML in here</title>
        </head>
        <body>
            <h1>Look ma! HTML!</h1>
        </body>
    </html>
    """
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 394 bytes
    - Click Count (0)
Back to Top