如果没有立即完成等待，Dart File.writeAsString() 方法不会写入文件

Question

我的以下 Dart 代码的行为与我预期的不同：

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

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(send("$i"));
  }
  for (int i = 0; i < 100; i++) {
    print(await futures[i]);
  }
}

我希望在第二个循环中对await futures[i] 的每次调用返回后立即写入文件。然而，这似乎并没有发生。

对于从 0 到 99 的每个索引，该文件应包含一行。但它包含一行 99，后跟一个空行。第二个循环中的打印调用总是打印相同的文件长度，3。

事件循环似乎以某种方式合并了调用，并且只实际执行了最后一个调用，尽管我仍然在第二个循环中等待了 100 个不同的未来。

为什么会发生这种情况，我怎样才能让期货运行而不立即等待它们（我真的只需要稍后等待，当所有对 send 的调用都已完成时）？

Answer 1

使用循环：

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

立即调用多个send，每个send同时打开并在文件中写入一个字符串：你有一个竞争条件，最后碰巧只有一条消息写入文件。

使用返回未来的函数列表

通过闭包，可以为文件访问实现一个序列化版本，从而避免竞争条件。

创建一个返回future的函数列表，而不是创建future列表： 如果您在循环中调用和等待此类函数，则会按顺序访问共享文件资源：

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]);
  }
}