Package org.apache.cassandra.repair

Interface Scheduler

All Known Implementing Classes:

Scheduler.LimitedConcurrentScheduler, Scheduler.NoopScheduler

public interface Scheduler

Task scheduler that limits the number of concurrent tasks across multiple executors.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final class	Scheduler.LimitedConcurrentScheduler
static final class	Scheduler.NoopScheduler
static class	Scheduler.Task<T>

Method Summary

Modifier and Type	Method	Description
static Scheduler	build(int concurrentValidations)
default <T> Future<T>	schedule(Supplier<Future<T>> task, Executor executor)
<T> Scheduler.Task<T>	schedule(Scheduler.Task<T> task, Executor executor)

Method Details

schedule

default <T> Future<T> schedule(Supplier<Future<T>> task,
 Executor executor)

schedule

<T> Scheduler.Task<T> schedule(Scheduler.Task<T> task,
 Executor executor)

build

static Scheduler build(int concurrentValidations)