- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 2,234 for toRead (0.2 sec)
-
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/testng/TestNGStaticLoggingIntegrationTest.groovy
public class OkTest { @Test public void ok() throws Exception { // logging from multiple threads List<Thread> threads = new ArrayList<Thread>(); for (int i = 0; i < 5; i++) { Thread thread = new Thread("thread " + i) { @Override public void run() { System.out.print("stdout from "); // print a partial line
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 5.9K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/internal/project/DefaultProjectStateRegistryTest.groovy
thread.block() state.applyToMutableState { // nested } assert state.hasMutableState() instant.thread1 } assert !state.hasMutableState() } workerThread { thread.blockUntil.start
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 24.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/InterruptibleRunnable.java
stateLock.lock(); try { thread = Thread.currentThread(); if (interrupted) { thread.interrupt(); } } finally { stateLock.unlock(); } } private void afterRun() { stateLock.lock(); try { Thread.interrupted(); thread = null; } finally { stateLock.unlock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/junit/AbstractJUnitLoggingOutputCaptureIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 7.5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerThreadRegistry.java
/** * Allows a thread to enlist in resource locking, for example to lock the mutable state of a project. */ @ServiceScope(Scope.BuildSession.class) public interface WorkerThreadRegistry { /** * Runs the given action as a worker. While the action is running, the thread can acquire resource locks. * A worker lease is also granted to the thread. The thread can release this if it needs to, but should reacquire
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 3.6K bytes - Viewed (0) -
src/test/java/org/codelibs/core/timer/TimeoutManagerTest.java
} }, 1, true); assertNotNull(TimeoutManager.getInstance().thread); Thread.sleep(2000); assertTrue(expiredCount > 0); assertEquals(1, TimeoutManager.getInstance().getTimeoutTaskCount()); TimeoutManager.getInstance().stop(); assertNull(TimeoutManager.getInstance().thread); Thread.sleep(10); int count = expiredCount; task.stop();
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
* state: BLOCKED, WAITING, or TIMED_WAITING. */ void waitForThreadToEnterWaitState(Thread thread, long timeoutMillis) { long startTime = System.nanoTime(); for (; ; ) { Thread.State s = thread.getState(); if (s == Thread.State.BLOCKED || s == Thread.State.WAITING || s == Thread.State.TIMED_WAITING) return;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
try { TestThread thread = new TestThread(this, lock, cl) thread.start() return thread } finally { lock.unlock() } } /** * Starts a thread which executes the given action/closure. Does not wait for the thread to complete. * * @return A handle to the test thread. */ TestParticipant start(Runnable cl) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/Instants.groovy
* accessed from the main thread, queries an existing instant, asserting that it exists. */ class Instants implements InstantFactory, OperationListener { private final Object lock = new Object() private final Map<String, NamedInstant> timePoints = [:] private Thread mainThread private final TestLogger logger
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.7K bytes - Viewed (0)