- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 503 for Rask (0.17 sec)
-
android/guava/src/com/google/common/util/concurrent/ListeningExecutorService.java
/** * @return a {@code ListenableFuture} representing pending completion of the task * @throws RejectedExecutionException {@inheritDoc} */ @Override <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task); /** * @return a {@code ListenableFuture} representing pending completion of the task * @throws RejectedExecutionException {@inheritDoc} */ @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Sun Jun 20 10:45:35 GMT 2021 - 4.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} }); Runnable task = new Runnable() { @Override public void run() { numCalls.incrementAndGet(); } }; assertThrows(RejectedExecutionException.class, () -> executor.execute(task)); assertEquals(0, numCalls.get()); reject.set(false); executor.execute(task); assertEquals(1, numCalls.get()); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
final TimeoutTask task = e.getElement(); if (task.isCanceled()) { e.remove(); } else if (!task.isStopped() && task.isExpired()) { expiredTask.add(task); if (!task.isPermanent()) { e.remove(); } } }
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
* is running when that time is reached, that task is allowed to complete before this task is * started. Similarly the task will be delayed if the host lacks compute resources. * * @throws RejectedExecutionException if the queue is shut down and the task is not cancelable. */ fun schedule( task: Task, delayNanos: Long = 0L, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/math/IntMathBenchmark.java
@Benchmark int pow(int reps) { int tmp = 0; for (int i = 0; i < reps; i++) { int j = i & ARRAY_MASK; tmp += IntMath.pow(positive[j], exponent[j]); } return tmp; } @Benchmark int mod(int reps) { int tmp = 0; for (int i = 0; i < reps; i++) { int j = i & ARRAY_MASK; tmp += IntMath.mod(ints[j], positive[j]); } return tmp; } @Benchmark
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 3.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
internal const val B0_FLAG_RSV3 = 16 /** Byte 0 mask for the frame opcode. */ internal const val B0_MASK_OPCODE = 15 /** Flag in the opcode which indicates a control frame. */ internal const val OPCODE_FLAG_CONTROL = 8 /** * Byte 1 flag for whether the payload data is masked. * * If this flag is set, the next four
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.8K bytes - Viewed (0) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.collect-failed-tasks.gradle.kts
println("##teamcity[buildProblem description='${buildScanUri}/console-log?task=$it']") } } } fun shouldBeReportedAsTeamCityBuildProblem(task: Task) = task is Checkstyle || task is GenerateReportsTask || task is AbstractCompile || task is CodeNarc abstract class CollectFailedTaskPathsBuildService : AbstractBuildScanInfoCollectingService() {
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Thu Aug 11 07:01:27 GMT 2022 - 2.3K bytes - Viewed (1) -
android/guava/src/com/google/common/collect/CompactHashMap.java
int hash = smearedHash(key); int mask = hashTableMask(); int tableIndex = hash & mask; int next = CompactHashing.tableGet(requireTable(), tableIndex); if (next == UNSET) { // uninitialized bucket if (newSize > mask) { // Resize and add new entry mask = resizeTable(mask, CompactHashing.newCapacity(mask), hash, newEntryIndex); } else {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Jun 26 21:02:13 GMT 2023 - 35.8K bytes - Viewed (0) -
guava/src/com/google/common/collect/CompactHashMap.java
int hash = smearedHash(key); int mask = hashTableMask(); int tableIndex = hash & mask; int next = CompactHashing.tableGet(requireTable(), tableIndex); if (next == UNSET) { // uninitialized bucket if (newSize > mask) { // Resize and add new entry mask = resizeTable(mask, CompactHashing.newCapacity(mask), hash, newEntryIndex); } else {
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Jun 26 21:02:13 GMT 2023 - 39.8K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/math/LessThanBenchmark.java
xLongs[i] = random.nextLong() & NONNEGATIVE_LONG_MASK; yLongs[i] = random.nextLong() & NONNEGATIVE_LONG_MASK; constant[i] = random.nextInt(); } } @Benchmark int branchFreeLtIntInlined(int reps) { int tmp = 0; for (int i = 0; i < reps; i++) { int j = i & SAMPLE_MASK; int x = xInts[j]; int y = yInts[j]; int z = constant[j];
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4K bytes - Viewed (0)