简介

之前介绍了很多dart中的异步编程技巧，不晓得大家有没有发现一个问题，如果是在java的异步编程中，必定会提到锁和并发机制，然而对于dart来说，如同素来没有听到多线程和并发的问题，这是为什么呢？

明天，给大家解说一下dart中的隔离机制，大家就明确了。

dart中的隔离机制

dart是一个单线程的语言，然而作为一个单线程的语言，dart却反对Future,Stream等异步个性。这一切都是隔离机制和事件循环带来的后果。

首先看一下dart中的隔离机制。

所谓隔离指的是dart运行的一个特定的空间，这个空间领有独自的内存和单线程的事件循环。

如下图所示：

在java或者c++等其余语言中，多个线程是共享内存空间的，尽管带来了并发和数据沟通的不便路径，然而同时也造成了并发编程的艰难。

因为咱们须要思考多线程之间数据的同步，于是额定多出了很多锁的机制，具体理解或者用过的人应该都会很懊恼。

多线程最大的缺点就是要求程序员的罗辑思维和编程技巧足够优良，这样才可能设计出完满运行的多线程程序。

然而在dart中，这些都不是什么问题。dart中所有的线程都领有本人的运行空间，这个线程的工作就是运行事件循环。

那么问题来了，主线程在处理事件循环，然而如果遇到了一个十分耗时的操作，该怎么办呢? 如果间接在主线程中运行，则可能会导致主线程的阻塞。

dart也充分考虑到了这个问题，所以dart提供了一个Isolate的类来对隔离进行治理。

因为dart程序自身就在一个Isolate中运行，所以如果在dart中定义一个Isolate，那么这个Isolate通常示意的是另外一个，须要和以后Isolate进行通信的Isolate。

生成一个Isolate

那么如何在以后的dart程序中生成一个Isolate呢？

Isolate提供了三种生成办法。

一个十分罕用的是Isolate的工厂办法spawn:

  external static Future<Isolate> spawn<T>(      void entryPoint(T message), T message,      {bool paused = false,      bool errorsAreFatal = true,      SendPort? onExit,      SendPort? onError,      @Since("2.3") String? debugName});

spawn会创立一个新的Isolate，调用它须要传入几个参数：

entryPoint示意的是生成新Isolate的时候须要调用的函数。entryPoint承受一个message参数。通常来说message是一个SendPort对象，用于两个Isolate之间的沟通。

paused示意新生成的Isolate是否处于暂停状态，他相当于：

isolate.pause(isolate.pauseCapability)

如果后续须要勾销暂停状态，则能够调用：

isolate.resume(isolate.pauseCapability)

errorsAreFatal 对应的是setErrorsFatal办法。

onExit对应的是addOnExitListener, onError对应的是addErrorListener。

debugName示意的是Isolate在调试的时候展现的名字。

如果spawn出错，则会抛出IsolateSpawnException异样：

class IsolateSpawnException implements Exception {  /// Error message reported by the spawn operation.  final String message;  @pragma("vm:entry-point")  IsolateSpawnException(this.message);  String toString() => "IsolateSpawnException: $message";}

spawn办法生成的是和以后代码一样的Isolate。如果想要应用不同的代码来生成，则能够应用spawnUri,通过传入对应的Uri地址，从而生成不一样的code。

external static Future<Isolate> spawnUri(      Uri uri,      List<String> args,      var message,      {bool paused = false,      SendPort? onExit,      SendPort? onError,      bool errorsAreFatal = true,      bool? checked,      Map<String, String>? environment,      @Deprecated('The packages/ dir is not supported in Dart 2')          Uri? packageRoot,      Uri? packageConfig,      bool automaticPackageResolution = false,      @Since("2.3")          String? debugName});

还有一种形式，就是应用Isolate的构造函数：

Isolate(this.controlPort, {this.pauseCapability, this.terminateCapability});

它有三个参数，第一个参数是controlPort，代表另外一个Isolate的控制权，前面两个capabilities是原isolate的子集，示意是否有pause或者terminate的权限。

个别用法如下：

Isolate isolate = findSomeIsolate();Isolate restrictedIsolate = Isolate(isolate.controlPort);untrustedCode(restrictedIsolate);

Isolate之间的交互

所有的dart代码都是运行在Isolate中的，而后代码只可能拜访同一个isolate内的class和value。那么多个isolate之间通信，能够ReceivePort和SendPort来实现。

先看下SendPort,SendPort是Capability的一种：

abstract class SendPort implements Capability 

SendPort用于向ReceivePort发送message, message能够有很多类型,包含：

Null，bool,int,double,String,List,Map,TransferableTypedData,SendPort和Capability。

留神，send动作是立马实现的。

事实上，SendPort是由ReceivePort来创立的。一个ReceivePort能够接管多个SendPort。

ReceivePort是Stream的一种：

abstract class ReceivePort implements Stream<dynamic>

作为Stream,它提供了一个listen用来解决接管到的音讯：

  StreamSubscription<dynamic> listen(void onData(var message)?,      {Function? onError, void onDone()?, bool? cancelOnError});

一个例子

讲了那么多原理，有的同学可能会问了，那么到底怎么用呢？

例子来了：

import 'dart:isolate';var isolate;void entryPoint(SendPort sendPort) {  int counter = 0;  sendPort.send("counter:$counter");}void main() async{  final receiver = ReceivePort();  receiver.listen((message) {    print( "接管到音讯 $message");  });  isolate = await Isolate.spawn(entryPoint, receiver.sendPort);}

在主线程中，咱们创立了一个ReceivePort，而后调用了它的listen办法来监听sendPort发过来的音讯。

而后spawn出一个新的Isolate，这个Isolate会在初始化之后，调用entryPoint办法。

在这个entryPoint办法中又应用sendPort向ReceivePort发送音讯。

最终运行，打印：

接管到音讯 counter:0

总结

以上就是dart中的隔离机制和Isolate的应用。

本文已收录于 http://www.flydean.com/25-dart-isolates/

最艰深的解读，最粗浅的干货，最简洁的教程，泛滥你不晓得的小技巧等你来发现！

欢送关注我的公众号:「程序那些事」,懂技术，更懂你！