使用循环:

for (int i = 0; i < 100; i++) {
  futures.add(send("$i"));
}

倍数 send 被立即调用,每个并发打开并在文件中写入一个字符串:您有一个竞争条件,在最后,只会有一条消息被写入文件。

使用返回未来的函数列表

有了闭包,就可以实现文件访问的序列化版本,从而避免竞争条件。

如果在循环中调用并等待这些函数,则会按顺序访问共享文件资源:

import 'dart:io';

final File file = File("result.csv");

typedef Future SendFunction();

Future send(String message) async {
  try {
    await file.writeAsString(message + '\n',
        mode: FileMode.append, flush: true);
  } catch (e) {
    print("Error: $e");
  }
  var l = await file.length();
  return l;
}

main() async {

  final futures = List<SendFunction>();
  //final futures = <Future>[];

  for (int i = 0; i < 100; i++) {
    //futures.add(send("$i"));
    futures.add(() => send("$i"));
  }

  for (int i = 0; i < 100; i++) {
    print(await futures[i]());
    //print(await futures[i]);
  }
}

同步包

synchronized 提供锁机制以防止对异步代码的并发访问。

在这种情况下,它可以用来避免对 result.csv

import 'dart:io';
import 'package:synchronized/synchronized.dart';

final File file = File("result.csv");
final lock = new Lock();

Future send(String message) async {
  try {
    await file.writeAsString(message + '\n',
        mode: FileMode.append, flush: true);
  } catch (e) {
    print("Error: $e");
  }
  return await file.length();
}

main() async {
  final futures = <Future>[];
  for (int i = 0; i < 100; i++) {
    futures.add(lock.synchronized(() => send("$i")));
  }
  for (int i = 0; i < 100; i++) {
    print(await futures[i]);
  }
}