我写了一个torrent下载的demo，看起来像这样：

var peers....

for(var i =0;i < length;i++){
   var peer = peers[i];
   peer.start((List<int> data){
      _downloadFile.write(begin,end,data);
   });
}

我的意思是有多个peer试图访问_file。

`_downloadFile` code looks like this:
   ....
   var _access = _file.open(mode:FileMode.writeOnlyAppend);
   ...
   Future write(int begin,int end, List<int> block) async{
       ....
       await _access.setPosition(begin);
       await _access.writeFrom(block);
       ....
   }

它会抛出异常：FileSystemException: An async operation is currently pending我认为原因是不同的fork调用setPosition，所以我尝试让每个fork等待写操作结束：

`_downloadFile` code look like this:
   ....
   var _access = _file.open(mode:FileMode.writeOnlyAppend);
   var _lock;
   ...
   Future write(int begin,int end, List<int> block) async{
       if(_lock != null) await _lock;
       var c = Completer();
       _lock = c.future;
       ....
       await _access.setPosition(begin);
       await _access.writeFrom(block);
       c.complete();
       ....
   }

如果我理解正确的话，当peer接收到数据时，它会调用write方法，然后它应该等待_lock完成，但我仍然得到FileSystemException。
现在我必须使用Stream，以及它的pause和resume方法来避免这个异常。
谁能告诉我最后一个密码有什么问题吗？为什么_lock不工作？Dart是否有类似“对象锁”的功能？
非常感谢！