- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 106 for Sait (0.15 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
} public void testJoinTimeoutMultiInterruptExpired() { /* * We don't "need" to schedule a thread completion at all here, but by doing * so, we come the closest we can to testing that the wait time is * appropriately decreased on each progressive join() call. */ TimedThread thread = TimedThread.createWithDelay(LONG_DELAY_MS); repeatedlyInterruptTestThread(20, tearDownStack);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 30.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TestLocking.java
byte[] buf = new byte[1024]; for (int ii = 0; ii < numIter; ii++) { synchronized (this) { ltime = System.currentTimeMillis(); wait(); } try { double r = Math.random(); if (r < 0.333) { f.exists(); // System.out.print('e');
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 3.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
manager.startAsync(); afterStarted.countDown(); // We do not call awaitHealthy because, due to races, that method may throw an exception. But // we really just want to wait for the thread to be in the failure callback so we wait for that // explicitly instead. failEnter.await(); assertFalse("State should be updated before calling listeners", manager.isHealthy()); // now we want to stop the services.
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* than the given time. The manager will become healthy after all the component services have * reached the {@linkplain State#RUNNING running} state. * * @param timeout the maximum time to wait * @param unit the time unit of the timeout argument * @throws TimeoutException if not all of the services have finished starting within the deadline
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
if (i == 10) { new Thread(() -> latch.countDown()).start(); } future.addListener(listenerLatch::countDown, exec); } assertSame(Boolean.TRUE, future.get()); // Wait for the listener latch to complete. listenerLatch.await(500, MILLISECONDS); exec.shutdown(); exec.awaitTermination(500, MILLISECONDS); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* <a href="https://developer.android.com/studio/build/shrink-code">R8 and Proguard</a>. * <li>It doesn't offer a way to wait for multiple events before taking action. For example, it * doesn't offer a way to wait for multiple producers to all report that they're "ready," nor * does it offer a way to batch multiple events from a single producer together.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Aug 25 16:37:57 GMT 2021 - 12.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheReferencesTest.java
// observe a size of 1 long initialSize = cache.size(); assertTrue(initialSize == 1 || initialSize == 2); // wait up to 5s byte[] filler = new byte[1024]; for (int i = 0; i < 500; i++) { System.gc(); CacheTesting.drainReferenceQueues(cache); if (cache.size() == 1) { break; }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
@Override public boolean cancel(boolean mayInterruptIfRunning) { throw new AssertionFailedError(); } @Override public V get() throws InterruptedException { /* * Wait a little to give us time to call addListener before the future's * value is set in addition to the call we'll make after then. */ allowGetToComplete.await(1, SECONDS);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 9.7K bytes - Viewed (0) -
android/guava/src/com/google/common/base/internal/Finalizer.java
} } } /** * Cleans up the given reference and any other references already in the queue. Catches and logs * all throwables. * * @return true if the caller should continue to wait for more references to be added to the * queue, false if the associated FinalizableReferenceQueue is no longer referenced. */ private boolean cleanUp(Reference<?> firstReference) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Aug 23 12:54:09 GMT 2023 - 9.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbComTransaction.java
static final int NET_SERVER_ENUM2 = 0x0068; static final int NET_SERVER_ENUM3 = 0x00D7; static final byte TRANS_PEEK_NAMED_PIPE = (byte)0x23; static final byte TRANS_WAIT_NAMED_PIPE = (byte)0x53; static final byte TRANS_CALL_NAMED_PIPE = (byte)0x54; static final byte TRANS_TRANSACT_NAMED_PIPE = (byte)0x26; protected int primarySetupOffset;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 10.5K bytes - Viewed (0)