タスクの実行順序を知る

タスク間の処理

rehearsalでは、TCP通信を行うプロセスや内部でアプリケーションを実行するプロセスをそれぞれ一個のタスクとして管理することを前の章で確認しました。しかし、rehearsalはその仕組み上、単一のタスクを回すだけではその真価を発揮することはありません。そこで、この段では複数のタスクがどのようにして組み合わさるのかを解説します。

そもそも、rehearsalは個々のタスクを監視し、その入出力を渡す事にしかその焦点を当てていません。この事から以下のような性質があります。

• rehearsalのタスクには依存関係がありません。
• rehearsalのタスクは並列的に実行されます。

例：循環接続

以下の例を見てください。以下の例ではTaskAとTaskBがお互いの標準出力を相手の標準入力に送信しています。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

version: 1.202109
phase:
- name: "example"
  task:
  - name: TaskA
    stdout:
      sendto: TaskB
  - name: TaskB
    stdout:
      sendto: TaskA    

この場合、以下のように連携を非同期に行います。

graph TB

subgraph TaskA
    Ain[rehearsal入力クエリ]
    A[プログラムA]
    Aout[rehearsal出力プロセス]
end
subgraph TaskB
    Bout[rehearsal出力プロセス]
    B[プログラムB]
    Bin[rehearsal入力クエリ]
end
Ain--stdin-->A
A--stdout-->Aout-.クエリに書き込み.->Bin
Bin--stdin-->B
B--stdout-->Bout-.クエリに書き込み.->Ain

この例のような循環接続は対話型のアルゴリズムの動作テストを行うのに非常に有用です。このような事例のために、rehearsalは依存関係を制限する構文に対して非常に消極的です。

システムタスク

ところで、rehearsal自身が各タスクの出力をログとして出力する際にもこのタスクは使用されています。上の例に書き足してみましょう。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

version: 1.202109
phase:
- name: "example"
  task:
  - name: TaskA
    stdout:
      sendto: TaskB
      write-log: true
  - name: TaskB
    stdout:
      sendto: TaskA
      write-log: true

この場合、rehearsalは内部にログ生成用のタスクを用意し、その標準入力に各タスクの標準出力を接続するので以下のようなプロセスを組むことになります。

graph TB

subgraph TaskA
    Ain[rehearsal入力クエリ]
    A[プログラムA]
    Aout[rehearsal出力プロセス]
end
subgraph TaskB
    Bout[rehearsal出力プロセス]
    B[プログラムB]
    Bin[rehearsal入力クエリ]
end
subgraph rehearsalログ
    Log[標準出力]
    Login[rehearsal入力クエリ]
end
Ain--stdin-->A--stdout-->Aout-.クエリに書き込み.->Bin & Login
Bin--stdin-->B--stdout-->Bout-.クエリに書き込み.->Ain & Login
Login-->Log

rehearsalのログはそれ自身もまたrehearsalの一個のタスクとして管理されているのです。しかし、rehearsalのログはその仕組み上、メモリを多く消費することがあるので使用は推奨できません。