async と future または channel を使って
WorkderModel1
と同じような pipeline 実行を実現してみよ。
まず、 すべての pipeline を実行してきちんと停止することを確認する 。