Dart library for running asynchronous functions on time. Useful for load balancing, rate limiting, lazy execution.
In the examples below, all the run calls are performed right
after object creation. In fact all the schedulers can handle
runs at random moments.
Runs tasks asynchronously, maintaining a fixed time interval between starts.
final scheduler = IntervalScheduler(delay: Duration(seconds: 1));
scheduler.run(()=>download('pageA')); // starts download immediately
scheduler.run(()=>download('pageB')); // will start one second later
scheduler.run(()=>download('pageC')); // will start two seconds laterRuns no more than N tasks in a certain period of time.
final scheduler = RateScheduler(3, Duration(seconds: 1)); // 3 per second
// the following tasks are executed immediately
scheduler.run(()=>download('pageA'));
scheduler.run(()=>download('pageB'));
scheduler.run(()=>download('pageC'));
// the following tasks are executed one second later
scheduler.run(()=>download('pageD'));
scheduler.run(()=>download('pageE'));
scheduler.run(()=>download('pageF'));
// the following tasks are executed two seconds later
scheduler.run(()=>download('pageG'));
scheduler.run(()=>download('pageH'));
scheduler.run(()=>download('pageI'));Limits the number of tasks running at the same time. This is somewhat similar to
using a thread pool or process pool. But it just runs
async functions.
// we will run a maximum of three tasks at the same time
final scheduler = ParallelScheduler(3);
scheduler.run(()=>asyncDownload('pageA')); // executed immediately
scheduler.run(()=>asyncDownload('pageB')); // executed immediately
scheduler.run(()=>asyncDownload('pageC')); // executed immediately
scheduler.run(()=>asyncDownload('pageD'));
// task for pageD will execute when some of the previous tasks finish Runs tasks asynchronously at the specified time.
final scheduler = TimeScheduler();
// run the function on January 1st at 17:75
scheduler.run(() { ... }, DateTime(2020, 1, 1, 17, 45));Runs only the last added task and only if no new tasks have been added during the time interval.
final scheduler = LazyScheduler(latency: Duration(seconds: 1));
scheduler.run(() => pushUpdate('1')); // maybe we will push 1
scheduler.run(() => pushUpdate('1+1')); // no we will push 1+1
scheduler.run(() => pushUpdate('1+1-1')); // no we will push 1+1-1
scheduler.run(() => pushUpdate('1')); // it's good we're so lazy
scheduler.run(() => pushUpdate('777')); // maybe we will push thisAnd one second later the scheduler runs pushUpdate('777'). Other tasks
are ignored.
We can continue with the same scheduler:
scheduler.run(()=>pushUpdate('13')); // we pushed 777, now we maybe push 13
scheduler.run(()=>pushUpdate('10')); // no, we will not push 13...Each of the schedulers allows you to wait for the result of the function
as a regular Future. You just have to await for the .result.
final a = await download('pageA');
final b = await scheduler.run(()=>download('pageB')).result;These two calls to the download function behave in much the same way. The only
difference is that the scheduler can delay the execution of the function for
suitable times.
Copyright © 2021 Artsiom iG. Released under the MIT License.
![github-actions[bot] avatar](https://avatars.githubusercontent.com/in/15368?v=4 "github-actions[bot]")
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent