simple_mutex 1.5.0

Simple but the best Mutex providing a exclusive write lock and shared read-only locks.

example/simple_mutex_example.dart

import 'dart:async';
import 'dart:io';
import 'dart:math';

import 'package:simple_mutex/simple_mutex.dart';

final mutex = Mutex();
final rand = Random();
final t = 1000;
var a = t;
var b = 0;

Future<void> mySleep(int ms) => Future.delayed(Duration(milliseconds: ms));

Future<void> move(int i) async {
  while (a > 0) {
    await mutex.critical(deliver: true, () async {
      var a2 = a;
      var r = min(rand.nextInt(10) + 1, a2);
      await mySleep(rand.nextInt(10));
      a = a2 - r;
      await mySleep(rand.nextInt(10));
      var b2 = b;
      await mySleep(rand.nextInt(10));
      b = b2 + r;
      await mySleep(rand.nextInt(10));
      stdout.write('M$i:$r ');
    });
  }
}

Future<void> observe(int i) async {
  while (a > 0) {
    await mutex.criticalShared(() async {
      stdout.write('O$i:${mutex.isLocked ? "l" : "u"}${mutex.sharedCount} ');
      if (a + b != t) {
        print('\nerror: $a + $b = ${a + b} != $t');
      }
      await mySleep(rand.nextInt(10));
    });
  }
}

Future<void> main() async {
  print('$a + $b = ${a + b}');
  var futures = <Future<void>>[];
  for (var i = 0; i < 5; i++) {
    futures.add(observe(i));
  }
  await null;
  for (var i = 0; i < 5; i++) {
    futures.add(move(i));
  }
  await Future.wait(futures);
  print('\n$a + $b = ${a + b}');
}