閃光的網站・弛緩複合体 -Review Division-

ParallelExecutor

ところで、ParallelExecutor というクラスがあります。

addThread()メソッドで登録した複数のスレッドを並行処理させるというものです。 使用する際は下記のような記述をおこないます。

override protected function run():void { var pexe:ParallelExecutor = new ParallelExecutor(); pexe.addThread(new SubThreadA()); pexe.addThread(new SubThreadB()); pexe.addThread(new SubThreadC()); pexe.start(); }

このクラスの挙動ですが、下記のような記述で普通に擬似マルチスレッドを実行させたときと、特に変わりがないように思えます。

override protected function run():void { var ta:SubThreadA = new SubThreadA(); var tb:SubThreadB = new SubThreadB(); var tc:SubThreadC = new SubThreadC(); ta.start(); tb.start(); tc.start(); }

join() で処理待ちをしなかったときは若干異なるようですが、基本的に ParallelExecutor を使っても使わなくてもマルチスレッドの挙動は同じって考えて良いんですかね（考えて良いらしい。前回の yossy さんのコメント参照）。

まぁでも join() を記述する際、ParallelExecutor を使わない場合は SubThreadA、B、C のうちどれが一番処理工程が長いのかということをコーダが意識しなければいけない、でもParallelExecutor を使えばそんなことに煩わされない。 この違いは大きいですよね。

あと、進捗状況取得は ParallelExecutor が必須か。

• ParallelExecutor のサンプルソース

SerialExecutor

ParallelExecutor の話が出たので、ここで対になるもうひとつの Executor である SerialExecutor についても見てみましょう。

これは、普通だったらマルチスレッドで動いてしまう複数のスレッドを、シングルスレッドとして順次実行したい場合に使用するクラスです。

記述方法は ParallelExecutor とまったく同じで以下のような感じ。

override protected function run():void { var sexe:SerialExecutor = new SerialExecutor(); sexe.addThread(new SubThreadA()); sexe.addThread(new SubThreadB()); sexe.addThread(new SubThreadC()); sexe.start(); }

実行結果は以下のとおり（各 SubThread は前回と同じものを使用）。

main f1
A f1
A f2
A f3
A f4
A finalize
B f1
B f2
B f3
B f4
B f5
B f6
B finalize
C f1
C f2
C finalize
main f2
D f1
E f1
main finalize
D f2
E f2
D f3
E f3
D finalize
E f4
E f5
E finalize

SubThreadA、B、C がそれぞれシングルスレッドとして処理されているのが分かるかと思います。

• SerialExecutor のサンプル

続く。

スポンサーサイト