- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 121 for QThread (2.24 sec)
-
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(); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Mar 04 16:54:11 GMT 2024 - 4.6K bytes - Viewed (0) -
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(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Mar 04 16:54:11 GMT 2024 - 4.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* <ol> * <li>When a thread attaches a listener to a {@code ListenableFuture} that's already * complete, the listener runs immediately in that thread. * <li>When a thread attaches a listener to a {@code ListenableFuture} that's * incomplete and the {@code ListenableFuture} later completes normally, the * listener runs in the thread that completes the {@code ListenableFuture}.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K 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();
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 2.1K bytes - Viewed (0) -
maven-compat/src/test/java/org/apache/maven/artifact/resolver/DefaultArtifactResolverTest.java
} seen = true; tg = aTgList; Thread[] ts = new Thread[tg.activeCount()]; tg.enumerate(ts); for (Thread active : ts) { String name = active.getName(); boolean daemon = active.isDaemon(); assertTrue(daemon, name + " is no daemon Thread."); } }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 05:46:50 GMT 2024 - 3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
coordinatorWaiting = false } } } } } /** Start another thread, unless a new thread is already scheduled to start. */ private fun startAnotherThread() { lock.assertHeld() if (executeCallCount > runCallCount) return // A thread is still starting. executeCallCount++ backend.execute(this@TaskRunner, runnable) }
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) -
src/main/java/org/codelibs/core/lang/ThreadUtil.java
import org.codelibs.core.log.Logger; /** * Utility class for Thread class * * @author shinsuke * */ public abstract class ThreadUtil { private static final Logger logger = Logger.getLogger(ThreadUtil.class); public static void sleep(final long millis) { if (millis < 1L) { return; } try { Thread.sleep(millis); } catch (final InterruptedException e) {
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 1.5K 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)