`Isolate.spawn` în Dart

Pornește un izolat de durată, care rulează o funcție cu un mesaj inițial; kill îl oprește.

Sintaxă

static Future<Isolate> spawn<T>(void entryPoint(T message), T message, {bool paused = false, bool errorsAreFatal = true, SendPort? onExit, SendPort? onError, String? debugName})
void kill({int priority = beforeNextEvent})

Ce face `Isolate.spawn`

Isolate.spawn(functie, mesaj) pornește un izolat nou care cheamă functie(mesaj). De obicei mesajul este un SendPort, prin care izolatul trimite rezultate înapoi. Funcția trebuie să fie de nivel de sus sau statică. Spre deosebire de Isolate.run, izolatul trăiește cât timp are ceva de făcut și poate trimite oricâte mesaje.

izolat.kill() oprește izolatul. Cu priority: Isolate.immediate se oprește cât mai repede; implicit, înainte de următorul eveniment. Cu onExit sau addOnExitListener primești un mesaj când izolatul s-a terminat.

Parametri

Parametru	Descriere
`entryPoint`	Funcția de nivel de sus rulată în izolatul nou.
`message`	Valoarea trimisă funcției (des, un `SendPort`).
`onExit / onError`	Opțional: porturi care primesc un mesaj la terminare sau la erori.
`priority`	Pentru `kill`: cât de repede se oprește izolatul.

Ce returnează

spawn: un Future<Isolate>. kill: nimic.

Exemple

Exemplul 1: Un lucrător care trimite rezultate pe rând

import 'dart:isolate';

void lucrator(SendPort raspuns) {
  for (final oras in ['Iași', 'Cluj', 'Timișoara']) {
    raspuns.send('$oras are ${oras.length} litere');
  }
  raspuns.send(null);
}

Future<void> main() async {
  final port = ReceivePort();
  await Isolate.spawn(lucrator, port.sendPort);
  await for (final mesaj in port) {
    if (mesaj == null) break;
    print(mesaj);
  }
  print('lucrătorul a terminat');
}

Rezultat

Iași are 4 litere
Cluj are 4 litere
Timișoara are 9 litere
lucrătorul a terminat

Exemplul 2: Oprirea unui izolat cu kill

import 'dart:async';
import 'dart:isolate';

void ceas(SendPort port) {
  var i = 0;
  Timer.periodic(const Duration(milliseconds: 10), (_) => port.send(++i));
}

Future<void> main() async {
  final mesaje = ReceivePort();
  final iesire = ReceivePort();
  final izolat = await Isolate.spawn(ceas, mesaje.sendPort, onExit: iesire.sendPort);

  final primele = await mesaje.take(3).toList();
  print('primite: $primele');
  izolat.kill(priority: Isolate.immediate);
  await iesire.first;
  print('izolatul s-a oprit');
  iesire.close();
}