Flutter并行处理插件parallelism的使用

Flutter并行处理插件parallelism的使用

（⚠️ 大部分相关的文档都包含在源代码中，请使用dartdoc生成全面的文档。）

虽然Dart/Flutter中的并发编程相对简单，但编写利用并发的代码仍然不是那么简单。这个包旨在简化这一过程。

主要特性

1. 设置长运行的Isolate需要四个Send/Receive端口，这非常繁琐。我们为您处理了这个“握手”过程。
2. 同样，Isolate返回的数据被类型化为dynamic也很烦人，我们也会处理这一点。因此，现在您无需在后台任务中处理烦人的类型转换输入。

代码规范

1. 库级设计与开发人员文档——解释为什么事情会以某种方式结束。添加代码规范和功能集的比较大纲以及其他技术细节。首先考虑设计，然后考虑开发人员需求。

2. 所有公共接口的文档。使用以下格式：

   一行描述该方法/类/事物的功能。

   参数

   • argName: 此参数的描述。

   异常

   • ExceptionName: 导致此异常的原因。

   注意事项

   • 列出所有内容，除了那一行描述。

   • 您可以强调从函数内部逻辑的特殊之处到与该函数相关的随机事实的任何内容。

3. 使用描述性的变量名。

4. 即使不使用返回值也不要忽略它们，使用虚拟变量（如_、__等）来处理它们。

5. 保持文件大小小。将大型“设计块”（例如颜色）拆分为更小的微型库（例如颜色工具、颜色调色板生成、颜色主题生成）。标记微型库为/// {@nodoc}（区分大小写）。

6. 使用export/show指令将微型库收集到单个库中（例如color.dart）。

外部资源

• Dart是否多线程？
• Isolates如何工作
• Dart Isolates：是什么、为什么以及如何！
• Flutter中的多线程

完整示例Demo

创建一个简单的并行处理任务

import 'package:flutter/material.dart';
import 'package:parallelism/parallelism.dart';

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(title: Text('Parallelism Demo')),
        body: Center(child: ParallelTaskExample()),
      ),
    );
  }
}

class ParallelTaskExample extends StatefulWidget {
  @override
  _ParallelTaskExampleState createState() => _ParallelTaskExampleState();
}

class _ParallelTaskExampleState extends State<ParallelTaskExample> {
  String _result = '';

  Future<void> _runParallelTask() async {
    final result = await Parallelism.run<int>(() async {
      // 在这里执行耗时操作
      await Future.delayed(Duration(seconds: 2));
      return 42;
    });

    setState(() {
      _result = 'Result: $result';
    });
  }

  @override
  Widget build(BuildContext context) {
    return Column(
      mainAxisAlignment: MainAxisAlignment.center,
      children: [
        ElevatedButton(
          onPressed: _runParallelTask,
          child: Text('Run Parallel Task'),
        ),
        SizedBox(height: 20),
        Text(_result),
      ],
    );
  }
}

解释

1. 导入库：首先，导入必要的库。

   import 'package:flutter/material.dart';
   import 'package:parallelism/parallelism.dart';
   

2. 主应用：定义一个基本的Flutter应用。

   void main() {
     runApp(MyApp());
   }
   

3. UI组件：创建一个包含按钮和文本显示结果的简单UI。

   class MyApp extends StatelessWidget {
     @override
     Widget build(BuildContext context) {
       return MaterialApp(
         home: Scaffold(
           appBar: AppBar(title: Text('Parallelism Demo')),
           body: Center(child: ParallelTaskExample()),
         ),
       );
     }
   }
   

4. 状态管理：创建一个状态管理类来处理并行任务的结果。

   class _ParallelTaskExampleState extends State<ParallelTaskExample> {
     String _result = '';
   
     Future<void> _runParallelTask() async {
       final result = await Parallelism.run<int>(() async {
         // 在这里执行耗时操作
         await Future.delayed(Duration(seconds: 2));
         return 42;
       });
   
       setState(() {
         _result = 'Result: $result';
       });
     }
   
     @override
     Widget build(BuildContext context) {
       return Column(
         mainAxisAlignment: MainAxisAlignment.center,
         children: [
           ElevatedButton(
             onPressed: _runParallelTask,
             child: Text('Run Parallel Task'),
           ),
           SizedBox(height: 20),
           Text(_result),
         ],
       );
     }
   }