CronusScheduler scheduler = new CronusScheduler();
for (int i = 0; i < numTasks; i++) {
Runnable task = new MyTask();
scheduler.schedule(task);
}
scheduler.start();
CronusQueue<String> queue = new CronusQueue<>();
queue.enqueue("item1");
queue.enqueue("item2");
String item = queue.dequeue();
CronusThreadPoolExecutor executor = new CronusThreadPoolExecutor();
for (int i = 0; i < numTasks; i++) {
Runnable task = new MyTask();
executor.execute(task);
}
executor.shutdown();
<dependencies>
<dependency>
<groupId>org.cronus-framework</groupId>
<artifactId>cronus-core</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
