Flutter并行并发任务处理插件isoworker的使用

简介

isoworker 是一个对 Isolate 类的封装，旨在简化并行处理任务的编写。它具有以下特点：

• 与Flutter的 compute 不同，它不会在任务执行时创建新的 Isolate 对象，而是复用现有的对象，因此开销更小。
• 支持通过 Future 进行任务流水线化。

使用方法

初始化

要使用 isoworker 插件，首先需要初始化 IsoWorker 实例。这通常涉及到提供一个顶层或静态方法作为参数，该方法接受 Stream<WorkerData> 类型的参数，并用于处理来自主隔离区的消息。

import 'package:isoworker/isoworker.dart';

void workerMethod(Stream<WorkerData> message) {
  final _map = {
    'key_1': 'val_1',
    'key_2': 'val_2',
  };
  
  message.listen((data) {
    final command = data.value['command'];
    switch (command) {
      case 'get':
        data.callback(_map[data.value['key']]);
        break;
      default:
        data.callback(null);
    }
  });
}

void main() async {
  final worker = await IsoWorker.init(workerMethod);
}

执行任务

一旦 IsoWorker 被成功初始化后，就可以通过调用其 exec 方法来执行特定的任务。这里我们演示了如何获取存储在 _map 中的值：

final res = await worker.exec({
  'command': 'get',
  'key': 'key_1',
});
print(res); // 输出: val_1

销毁 Worker

当不再需要 IsoWorker 时，记得调用 dispose 方法释放资源：

await worker.dispose();

示例代码

下面是一个完整的示例程序，展示了如何使用 isoworker 来执行延迟操作以及比较不同方式之间的性能差异：

import 'dart:isolate';
import 'package:isoworker/isoworker.dart';

void workerMethod(Stream<WorkerData> message) {
  final sampleMap = {
    'key_1': 'val_1',
    'key_2': 'val_2',
  };

  message.listen((data) {
    final command = data.value['command'];
    switch (command) {
      case 'get':
        data.callback(sampleMap[data.value['key']]);
        break;
      case 'wait':
        Future.delayed(Duration(milliseconds: 200)).then((_) {
          data.callback(sampleMap[data.value['key']]);
        });
        break;
      default:
        data.callback(null);
    }
  });
}

String? workerMethod2(String key) {
  final sampleMap = {
    'key_1': 'val_1',
    'key_2': 'val_2',
  };
  return sampleMap[key];
}

void main() async {
  final worker = await IsoWorker.init(workerMethod);

  // 执行多个异步任务
  final exec1 = worker.exec({
    'command': 'wait',
    'key': 'key_1',
  });
  final exec2 = worker.exec({
    'command': 'get',
    'key': 'key_2',
  });
  final res = await Future.wait([exec1, exec2]);
  print(res);

  // 性能测试
  final stopwatch = Stopwatch();
  stopwatch.start();
  for (var i = 0; i < 100; i++) {
    await worker.exec({
      'command': 'get',
      'key': 'key_1',
    });
  }
  stopwatch.stop();
  print('isoworker:${stopwatch.elapsedMilliseconds}ms');

  stopwatch.reset();
  stopwatch.start();
  for (var i = 0; i < 100; i++) {
    await Isolate.run(() => workerMethod2('key_1'));
  }
  stopwatch.stop();
  print('Isolate.run:${stopwatch.elapsedMilliseconds}ms');

  await worker.dispose();
}

此示例不仅展示了如何利用 isoworker 插件执行基本任务，还提供了关于其性能优势的具体数据对比。希望这些信息能够帮助你更好地理解和应用这个强大的工具！