- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 221 for schedule (0.28 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
private ScheduledFuture<@Nullable Void> submitToExecutor(Schedule schedule) { return executor.schedule(this, schedule.delay, schedule.unit); } } /** * Contains the most recently submitted {@code Future}, which may be cancelled or updated, * always under a lock. */ private static final class SupplantableFuture implements Cancellable { private final ReentrantLock lock;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
// If the task is already scheduled, take the earlier of the two times. val existingIndex = futureTasks.indexOf(task) if (existingIndex != -1) { if (task.nextExecuteNanoTime <= executeNanoTime) { taskRunner.logger.taskLog(task, this) { "already scheduled" } return false } futureTasks.removeAt(existingIndex) // Already scheduled later: reschedule below! }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
assertEquals(UNIT, unit); assertEquals(testRunnable, command); } public void testFixedRateSchedule() { Scheduler schedule = Scheduler.newFixedRateSchedule(INITIAL_DELAY, DELAY, UNIT); Cancellable unused = schedule.schedule( null, new ScheduledThreadPoolExecutor(1) { @Override public ScheduledFuture<?> scheduleAtFixedRate(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
object : Task("task one") { val schedules = mutableListOf(200.µs) override fun runOnce(): Long { if (schedules.isNotEmpty()) { redQueue.schedule(this, schedules.removeAt(0)) // Add it at the end also. } log += "scheduledTasks=${redQueue.scheduledTasks}" return -1L } } redQueue.schedule(task, 100.µs)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 20K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
assertEquals(UNIT, unit); assertEquals(testRunnable, command); } public void testFixedRateSchedule() { Scheduler schedule = Scheduler.newFixedRateSchedule(INITIAL_DELAY, DELAY, UNIT); Cancellable unused = schedule.schedule( null, new ScheduledThreadPoolExecutor(1) { @Override public ScheduledFuture<?> scheduleAtFixedRate(
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
} @Test fun taskFailsWithUncheckedException() { queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(100)) { log.put("failing task running") throw RuntimeException("boom!") } queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) { log.put("normal task running") return@schedule -1L } queue.idleLatch().await(500, TimeUnit.MILLISECONDS)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
.github/dependabot.yml
--- version: 2 updates: - package-ecosystem: gomod directory: / schedule: interval: weekly - package-ecosystem: github-actions directory: / schedule: interval: weekly - package-ecosystem: gomod directory: /tests schedule:
Others - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Mon Aug 09 05:16:25 GMT 2021 - 287 bytes - Viewed (0) -
.github/dependabot.yml
Others - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Mar 29 17:59:22 GMT 2021 - 440 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* ---------- * * Tasks control their recurrence schedule. The [runOnce] function returns -1L to signify that the * task should not be executed again. Otherwise it returns a delay until the next execution. * * A task has at most one next execution. If the same task instance is scheduled multiple times, the * earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and * those implied by the returned execution delay.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java
} @Override public final ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return delegate.schedule(wrapTask(command), delay, unit); } @Override public final <V extends @Nullable Object> ScheduledFuture<V> schedule( Callable<V> task, long delay, TimeUnit unit) { return delegate.schedule(wrapTask(task), delay, unit); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 2.4K bytes - Viewed (0)