Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 library dart.pkg.isolate.isolaterunner_test; | 5 library dart.pkg.isolate.isolaterunner_test; |
| 6 | 6 |
| 7 import "package:isolate/isolaterunner.dart"; | 7 import "package:isolate/isolaterunner.dart"; |
| 8 import "package:unittest/unittest.dart"; | 8 import "package:unittest/unittest.dart"; |
| 9 import "dart:async" show Future; | 9 import "dart:async" show Future; |
| 10 import "dart:isolate" show Capability; | 10 import "dart:isolate" show Capability; |
| (...skipping 17 matching lines...) Expand all Loading... | |
| 28 return IsolateRunner.spawn().then((IsolateRunner runner) { | 28 return IsolateRunner.spawn().then((IsolateRunner runner) { |
| 29 return runner.run(id, "testCreateRunClose").then((v) { | 29 return runner.run(id, "testCreateRunClose").then((v) { |
| 30 expect(v, "testCreateRunClose"); | 30 expect(v, "testCreateRunClose"); |
| 31 return runner.close().then((_) => runner.onExit); | 31 return runner.close().then((_) => runner.onExit); |
| 32 }); | 32 }); |
| 33 }); | 33 }); |
| 34 } | 34 } |
| 35 | 35 |
| 36 Future testSeparateIsolates() { | 36 Future testSeparateIsolates() { |
| 37 // Check that each isolate has its own _global variable. | 37 // Check that each isolate has its own _global variable. |
| 38 return Future.wait(new Iterable.generate(2, (_) => IsolateRunner.spawn())) | 38 return Future |
| 39 .then((runners) { | 39 .wait(new Iterable.generate(2, (_) => IsolateRunner.spawn())) |
| 40 Future runAll(action(IsolateRunner runner, int index)) { | 40 .then((runners) { |
| 41 var indices = new Iterable.generate(runners.length); | 41 Future runAll(action(IsolateRunner runner, int index)) { |
|
Lasse Reichstein Nielsen
2015/02/26 10:59:15
Indent body by four more.
| |
| 42 return Future.wait(indices.map((i) => action(runners[i], i))); | 42 var indices = new Iterable.generate(runners.length); |
| 43 } | 43 return Future.wait(indices.map((i) => action(runners[i], i))); |
| 44 } | |
| 44 | 45 |
| 45 return runAll((runner, i) => runner.run(setGlobal, i + 1)) | 46 return runAll((runner, i) => runner.run(setGlobal, i + 1)).then((values) { |
|
Lasse Reichstein Nielsen
2015/02/26 10:59:15
This one is acceptable, but I still think it's bet
| |
| 46 .then((values) { | 47 expect(values, [1, 2]); |
| 47 expect(values, [1, 2]); | 48 expect(_global, null); |
| 48 expect(_global, null); | 49 return runAll((runner, _) => runner.run(getGlobal, null)); |
| 49 return runAll((runner, _) => runner.run(getGlobal, null)); | 50 }).then((values) { |
| 50 }) | 51 expect(values, [1, 2]); |
| 51 .then((values) { | 52 expect(_global, null); |
| 52 expect(values, [1, 2]); | 53 return runAll((runner, _) => runner.close()); |
| 53 expect(_global, null); | |
| 54 return runAll((runner, _) => runner.close()); | |
| 55 }); | |
| 56 }); | 54 }); |
| 55 }); | |
| 57 } | 56 } |
| 58 | 57 |
| 59 void testIsolateFunctions() { | 58 void testIsolateFunctions() { |
| 60 test("pause", () { | 59 test("pause", () { |
| 61 bool mayComplete = false; | 60 bool mayComplete = false; |
| 62 return IsolateRunner.spawn().then((isolate) { | 61 return IsolateRunner.spawn().then((isolate) { |
| 63 isolate.pause(); | 62 isolate.pause(); |
| 64 new Future.delayed(MS * 500, () { | 63 new Future.delayed(MS * 500, () { |
| 65 mayComplete = true; | 64 mayComplete = true; |
| 66 isolate.resume(); | 65 isolate.resume(); |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 105 return isolate.kill(); | 104 return isolate.kill(); |
| 106 }); | 105 }); |
| 107 }); | 106 }); |
| 108 } | 107 } |
| 109 | 108 |
| 110 id(x) => x; | 109 id(x) => x; |
| 111 | 110 |
| 112 var _global; | 111 var _global; |
| 113 getGlobal(_) => _global; | 112 getGlobal(_) => _global; |
| 114 void setGlobal(v) => _global = v; | 113 void setGlobal(v) => _global = v; |
| OLD | NEW |