agilord / executor Goto Github PK

View Code? Open in Web Editor NEW

15.0 15.0 2.0 42 KB

Async task executor for Dart

License: BSD 3-Clause "New" or "Revised" License

Dart 100.00%

executor's People

Contributors

Stargazers

Watchers

Forkers

davidmartos96 yiiim

executor's Issues

when run sample code but don't true?

void func(String msg){
//sleep(const Duration(seconds:1));
print(msg);
}

Executor executor = new Executor(concurrency: 5);
for (int i = 0; i < 20; i++) {
executor.scheduleTask(() async {
// await longDatabaseTask()
// await anotherProcessing()
await func(i.toString());

  print('concurrency :${executor.concurrency}'); //don't true
  print('runningCount :${executor.runningCount}'); //don't true
  print('scheduledCount :${executor.scheduledCount}'); //don't true
  print('waitingCount :${executor.waitingCount}');  //don't true
  print('------------');

});
print("main thread");

}

Exceptions cannot be caught via `join`

Example code:

import 'package:executor/executor.dart';

void main() async {
  final executor = Executor(concurrency: 10);
// only 10 of them will be running at a time
  for (var i = 0; i < 20; i++) {
    // ignore: unawaited_futures
    executor.scheduleTask(() async {
      if (i == 5) {
        throw Exception('test');
      }
    });
  }

  try {
    await executor.join(withWaiting: true);
    await executor.close();
  } catch (err) {
    print('caught exception: $err');
  }
}

Output:

Unhandled exception:
Exception: test
example\executor.dart 10:9                     main.<fn>
package:executor/src/executor_impl.dart 61:29  _Executor.scheduleTask