add compute

Author: p0dyakov

README.md

@@ -1 +1,2 @@
-# Flutter Multithreading
+# Flutter Multithreading
+https://habr.com/ru/post/532862/

lib/notifier.dart

@@ -1,19 +1,22 @@
 import 'dart:isolate';
 
+import 'package:flutter/foundation.dart';
 import 'package:flutter/material.dart';
 import 'package:flutter_riverpod/flutter_riverpod.dart';
 
 enum TestType { createNumbersArray, calculateFactorial }
 
 class TestResult {
   final Duration mainThreadExecutionTime;
-  final Duration anotherThreadExecutionTime;
+  final Duration isolateExecutionTime;
+  final Duration computeExecutionTime;
   final TestType testType;
 
   TestResult({
     required this.testType,
+    required this.computeExecutionTime,
     required this.mainThreadExecutionTime,
-    required this.anotherThreadExecutionTime,
+    required this.isolateExecutionTime,
   });
 }
 
@@ -27,33 +30,40 @@ class TestsController extends ChangeNotifier {
     isTestRunning = true;
     notifyListeners();
 
-    late final Future<void> Function() test;
+    late final Future<void> Function(int number) test;
+    late final int testNumber;
 
     switch (testType) {
       case TestType.createNumbersArray:
-        test = () => createNumbersArray(10000);
+        test = createNumbersArray;
+        testNumber = 10000;
         break;
       case TestType.calculateFactorial:
-        test = () => calculateFactorial(50);
+        test = calculateFactorial;
+        testNumber = 50;
         break;
     }
 
-    final anotherThreadExecutionTime = await measureExecutionTime(
-      () => workInBackground(
+    final isolateExecutionTime = await measureExecutionTime(
+      () => workInIsolate(
         (port) async {
-          await test();
+          await test(testNumber);
           Isolate.exit(port, 'canceled');
         },
       ),
     );
     final mainThreadExecutionTime = await measureExecutionTime(() async {
-      await test();
+      await test(testNumber);
+    });
+    final computeExecutionTime = await measureExecutionTime(() async {
+      await compute<int, void>(test, testNumber);
     });
 
     isTestRunning = false;
     results.add(
       TestResult(
-        anotherThreadExecutionTime: anotherThreadExecutionTime,
+        computeExecutionTime: computeExecutionTime,
+        isolateExecutionTime: isolateExecutionTime,
         mainThreadExecutionTime: mainThreadExecutionTime,
         testType: TestType.createNumbersArray,
       ),
@@ -77,7 +87,7 @@ Future<Duration> measureExecutionTime(
   return stopwatch.elapsed;
 }
 
-Future<void> workInBackground(void Function(SendPort) test) async {
+Future<void> workInIsolate(void Function(SendPort) test) async {
   final port = ReceivePort('test');
   await Isolate.spawn(test, port.sendPort);
   await port.first;

lib/test_widget.dart

@@ -17,7 +17,7 @@ class TestWidget extends StatelessWidget {
           const SizedBox(height: 10),
           Text(
             'In Isolate: ' +
-                result.anotherThreadExecutionTime.inMilliseconds.toString() +
+                result.isolateExecutionTime.inMilliseconds.toString() +
                 ' milliseconds',
           ),
           const SizedBox(height: 2),
@@ -26,6 +26,12 @@ class TestWidget extends StatelessWidget {
                 result.mainThreadExecutionTime.inMilliseconds.toString() +
                 ' milliseconds',
           ),
+          const SizedBox(height: 2),
+          Text(
+            'In Compute: ' +
+                result.computeExecutionTime.inMilliseconds.toString() +
+                ' milliseconds',
+          ),
         ],
       );
 }