TransferableTypeData added (#116)

isolate_example/lib/page_three.dart

@@ -11,10 +11,11 @@
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
-import 'package:flutter/material.dart';
-import 'package:provider/provider.dart';
+import 'dart:typed_data';
 import 'dart:isolate';
 import 'dart:math';
+import 'package:flutter/material.dart';
+import 'package:provider/provider.dart';
 
 class DataTransferPageStarter extends StatelessWidget {
   @override
@@ -67,7 +68,7 @@ class DataTransferIsolateController extends ChangeNotifier {
   SendPort _newIceSP;
 
   final currentProgress = <String>[];
-  bool running = false;
+  int runningTest = 0;
   Stopwatch _timer = Stopwatch();
   double progressPercent = 0;
 
@@ -93,7 +94,7 @@ class DataTransferIsolateController extends ChangeNotifier {
       }
 
       if (message is String && message == 'done') {
-        running = false;
+        runningTest = 0;
         _timer.stop();
       }
 
@@ -103,25 +104,30 @@ class DataTransferIsolateController extends ChangeNotifier {
 
   void generateOnSecondaryIsolate() {
     if (running) return;
-
-    running = true;
-    _timer.reset();
+    runningTest = 3;
     currentProgress.clear();
 
+    _timer = Stopwatch();
     _timer.start();
     _newIceSP.send('start');
 
     notifyListeners();
   }
 
-  Future<void> generateRandomNumbers() async {
+  Future<void> generateRandomNumbers(bool transferableTyped) async {
     if (running) return;
 
-    running = true;
+    if (transferableTyped) {
+      runningTest = 2;
+    } else {
+      runningTest = 1;
+    }
+
     Random rng = Random();
-    _timer = Stopwatch();
 
     currentProgress.clear();
+
+    _timer.reset();
     _timer.start();
 
     List<int> randNums = [];
@@ -131,11 +137,18 @@ class DataTransferIsolateController extends ChangeNotifier {
       for (int j = 0; j < 1000000; j++) {
         randNums.add(rng.nextInt(100));
       }
-      await sendNumbers(randNums);
+
+      if (transferableTyped) {
+        final transferable =
+            TransferableTypedData.fromList([Int32List.fromList(randNums)]);
+        await sendNumbers(transferable);
+      } else {
+        await sendNumbers(randNums);
+      }
     }
   }
 
-  Future<void> sendNumbers(List<int> numList) async {
+  Future<void> sendNumbers(dynamic numList) async {
     return Future<void>(() {
       _newIceSP.send(numList);
     });
@@ -143,6 +156,8 @@ class DataTransferIsolateController extends ChangeNotifier {
 
   Isolate get newIsolate => _newIsolate;
 
+  bool get running => runningTest != 0;
+
   void dispose() {
     super.dispose();
     _newIsolate?.kill(priority: Isolate.immediate);
@@ -186,17 +201,26 @@ class RunningList extends StatelessWidget {
 Future<void> _secondIsolateEntryPoint(SendPort callerSP) async {
   ReceivePort newIceRP = ReceivePort();
   callerSP.send(newIceRP.sendPort);
+  int length = 1;
 
   newIceRP.listen(
     (dynamic message) async {
       if (message is String && message == 'start') {
-        await generateAndSum(callerSP, createNums());
+        await generateAndSum(callerSP, createNums(), length);
 
         callerSP.send('done');
-      } else {
-        await generateAndSum(callerSP, message as List<int>);
+      } else if (message is TransferableTypedData) {
+        await generateAndSum(
+            callerSP, message.materialize().asInt32List(), length);
+        length++;
+      } else if (message is List<int>) {
+        await generateAndSum(callerSP, message, length);
+        length++;
+      }
 
+      if (length == 101) {
         callerSP.send('done');
+        length = 1;
       }
     },
   );
@@ -209,16 +233,17 @@ Iterable<int> createNums() sync* {
   }
 }
 
-Future<void> generateAndSum(SendPort callerSP, Iterable<int> iter) async {
+Future<void> generateAndSum(
+    SendPort callerSP, Iterable<int> iter, int length) async {
   int sum = 0;
-  int count = 0;
+  int count = 1;
 
   for (int x in iter) {
     sum += x;
-    count++;
-    if ((count + 1) % 1000000 == 0) {
-      callerSP.send((count + 1) ~/ 1000000);
+    if (count % 1000000 == 0) {
+      callerSP.send((count ~/ 1000000) * length);
     }
+    count++;
   }
 
   return sum;
@@ -235,11 +260,25 @@ Widget createButtons(BuildContext context) {
           RaisedButton(
             child: const Text('Transfer Data to 2nd Isolate'),
             elevation: 8.0,
-            onPressed: controller.generateRandomNumbers,
+            color: (controller.runningTest == 1)
+                ? Colors.blueAccent
+                : Colors.grey[300],
+            onPressed: () => controller.generateRandomNumbers(false),
+          ),
+          RaisedButton(
+            child: const Text('Transfer Data with TransferableTypedData'),
+            elevation: 8.0,
+            color: (controller.runningTest == 2)
+                ? Colors.blueAccent
+                : Colors.grey[300],
+            onPressed: () => controller.generateRandomNumbers(true),
           ),
           RaisedButton(
             child: const Text('Generate on 2nd Isolate'),
             elevation: 8.0,
+            color: (controller.runningTest == 3)
+                ? Colors.blueAccent
+                : Colors.grey[300],
             onPressed: controller.generateOnSecondaryIsolate,
           ),
         ],