- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 109 for 5000 (0.46 sec)
-
android/guava/src/com/google/common/util/concurrent/RateLimiter.java
* second. This could be accomplished by requiring a permit per byte, and specifying a rate of 5000 * permits per second: * * <pre>{@code * final RateLimiter rateLimiter = RateLimiter.create(5000.0); // rate = 5000 permits per second * void submitPacket(byte[] packet) { * rateLimiter.acquire(packet.length); * networkService.send(packet); * } * }</pre> *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 18.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
* @author Justin T. Sampson */ public final class TestThread<L> extends Thread implements TearDown { private static final long DUE_DILIGENCE_MILLIS = 100; private static final long TIMEOUT_MILLIS = 5000; private final L lockLikeObject; private final SynchronousQueue<Request> requestQueue = new SynchronousQueue<>(); private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<>();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 10.9K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/collect/MapBenchmark.java
} return builder.build(); } }; abstract Map<Element, Element> create(Collection<Element> contents); } @Param({"5", "50", "500", "5000", "50000"}) private int size; // TODO: look at exact (==) hits vs. equals() hits? @Param("0.9") private double hitRate; @Param("true") private boolean isUserTypeFast;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 7.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
RateLimiter limiter = RateLimiter.create(2.0, 4000, MILLISECONDS, 3.0, stopwatch); for (int i = 0; i < 8; i++) { limiter.acquire(); // #1 } stopwatch.sleepMillis(500); // #2: to repay for the last acquire stopwatch.sleepMillis(4000); // #3: becomes cold again for (int i = 0; i < 8; i++) { limiter.acquire(); // // #4 } stopwatch.sleepMillis(500); // #5: to repay for the last acquire
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
* @author Justin T. Sampson */ public final class TestThread<L> extends Thread implements TearDown { private static final long DUE_DILIGENCE_MILLIS = 100; private static final long TIMEOUT_MILLIS = 5000; private final L lockLikeObject; private final SynchronousQueue<Request> requestQueue = new SynchronousQueue<>(); private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<>();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 10.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
mmHeap.addAll( Lists.newArrayList(1, 20, 1000, 2, 3, 30, 40, 10, 11, 12, 13, 200, 300, 500, 400)); assertTrue("Heap is not intact initially", mmHeap.isIntact()); Iterator<Integer> it = mmHeap.iterator(); assertEquals((Integer) 1, it.next()); assertEquals((Integer) 20, it.next()); assertEquals((Integer) 1000, it.next()); assertEquals((Integer) 2, it.next()); it.remove();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 36.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
RateLimiter limiter = RateLimiter.create(2.0, 4000, MILLISECONDS, 3.0, stopwatch); for (int i = 0; i < 8; i++) { limiter.acquire(); // #1 } stopwatch.sleepMillis(500); // #2: to repay for the last acquire stopwatch.sleepMillis(4000); // #3: becomes cold again for (int i = 0; i < 8; i++) { limiter.acquire(); // // #4 } stopwatch.sleepMillis(500); // #5: to repay for the last acquire
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheBuilderTest.java
*/ @GwtIncompatible // QueuingRemovalListener public void testRemovalNotification_get_basher() throws InterruptedException { int nTasks = 1000; int nThreads = 100; final int getsPerTask = 1000; final int nUniqueKeys = 10000; final Random random = new Random(); // Randoms.insecureRandom(); QueuingRemovalListener<String, String> removalListener = queuingRemovalListener();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 25.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/MoreFilesTest.java
* not possible to protect against this if the file system doesn't. */ public void testDirectoryDeletion_directorySymlinkRace() throws IOException { int iterations = isAndroid() ? 100 : 5000; for (DirectoryDeleteMethod method : EnumSet.allOf(DirectoryDeleteMethod.class)) { try (FileSystem fs = newTestFileSystem(SECURE_DIRECTORY_STREAM)) { Path dirToDelete = fs.getPath("dir/b/i");
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Jan 29 22:57:05 GMT 2024 - 27.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// and the approximate actual delay, to be robust to variance in thread scheduling. char overWaitNanosFirstDigit = Long.toString( thread.timeSpentBlocked - TimeUnit.MILLISECONDS.toNanos(longWait ? 5000 : 3000)) .charAt(0); if (overWaitNanosFirstDigit < '4') { overWaitNanosFirstDigit = '9'; } String nanosRegex = "[4-" + overWaitNanosFirstDigit + "][0-9]+"; assertWithMessage(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0)