Golang に基づいて開発されたタスクフロー フレームワークを共有する

Go は、効率性、シンプルさ、拡張性の容易さで知られる人気のプログラミング言語です。同時に並行プログラミングに適した言語でもあり、Goroutine や Channel 機構により並行プログラミングが非常に容易になります。今回はGolangをベースに開発された、タスク処理を非常に便利に記述できるタスクフローフレームワークを紹介します。以下に、その使用法を簡単に紹介します。

タスクフロー API

タスクフロー フレームワークには、次の 3 つの重要な API があります。

1. NewTaskflow(): 使用されます。新しいタスクプロセスを宣言します。
2. AddTask(): タスク プロセスに新しいタスクを追加するために使用されます。このメソッドには通常、タスク名、タスク コード、タスク実行関数の 3 つのパラメータが必要です。
3. Start(): タスクプロセスを開始するために使用されます。

最も単純な例を見てみましょう:

package main

import (
    "fmt"
    "github.com/trustasia-com/taskflow"
)

func main() {
    // 声明一个新的Taskflow
    tf := taskflow.NewTaskflow()
    // 添加一个名为“hello”的任务，并将任务代码设为1
    tf.AddTask("hello", 1, func(tf *taskflow.Taskflow) error {
        fmt.Println("Hello, Taskflow")
        return nil
    })
    // 启动任务流程
    tf.Start()
}

上記の例から、最初に新しいタスク プロセスを宣言し、次に「hello」の名前を追加していることがわかります。 「タスク」では、いよいよタスク処理が開始されます。タスクコードではメッセージを出力するだけです。プログラムを実行すると、出力は次のようになります。

Hello, Taskflow

この例は単純ですが、タスクフローの概念と使用法の基本を理解できます。

タスクフローのタスク

タスクフローでは、各タスクは独立した実行単位であり、あらかじめ決められた順序で順番に実行することができます。各タスクには一意の名前と実行コードがあります。タスクは実行コード内でタスクフロー オブジェクトにアクセスできるため、他のタスクの実行ステータスや他のタスクを呼び出すコードを知ることができます。次に、タスクフローを使用して単純なタスク プロセスを構築する方法を見てみましょう。

package main

import (
    "fmt"
    "github.com/trustasia-com/taskflow"
)

func main() {
    // 声明一个新的Taskflow
    tf := taskflow.NewTaskflow()

    // 添加三个名称为“t1”、“t2”和“t3”的任务
    tf.AddTask("t1", 1, func(tf *taskflow.Taskflow) error {
        fmt.Println("This is Task 1")
        return nil
    })
    tf.AddTask("t2", 2, func(tf *taskflow.Taskflow) error {
        fmt.Println("This is Task 2")
        return nil
    })
    tf.AddTask("t3", 3, func(tf *taskflow.Taskflow) error {
        fmt.Println("This is Task 3")
        return nil
    })

    // 在Taskflow中，Task可以通过其名称进行引用
    // 这里我们添加了一些依赖
    tf.Link("t1", "t2")
    tf.Link("t2", "t3")

    // 启动任务流程
    tf.Start()
}

上記のコードでは、3 つのタスクを使用し、順番に追加しました。各タスクの実行コードでは、タスクの名前を出力します。

タスク プロセスの制御

タスクフロー タスク プロセスでは、タスク間のドライバーを制御することで、タスクの実行シーケンスと相互依存関係をカスタマイズすることもできます。これは、タスクフローの Link メソッドを通じて実現できます。 Link メソッドは、ソース タスクの名前とターゲット タスクの名前という 2 つのパラメーターを受け入れます。たとえば、次のコード スニペットでは、タスク 1 が完了した後にタスク 2 とタスク 3 がポストオペレーションとして追加されます。

...
// 启动任务流程
tf.Start()
// 添加一个名称为“t4”的Task，并将其添加到“t1”之后
tf.AddTask("t4", 4, func(tf *taskflow.Taskflow) error {
    fmt.Println("This is Task 4")
    return nil
})
tf.Link("t1", "t4")
tf.Link("t4", "t2")
tf.Link("t4", "t3")
// 停止任务流程
tf.Stop()
...

このコードでは、新しいタスク (タスク 4) を追加し、それをリンク メソッドで渡します。 Task1 の後の事後操作として。したがって、Task1 が完了した後、Task4 は完全に並行して実行されます。また、Task2 と Task3 を Task4 の後にリンクして、Task4 の実行直後にそれらが開始されるようにしました。

概要

この記事では、タスクフロー フレームワークとその簡単な使用法を紹介します。タスクフローが提供する API は非常にシンプルで実用的ですが、ほとんどのタスク プロセス操作を完了するには十分です。実際のアプリケーションでは、タスクフローを使用するとタスク プロセスを簡単に定義および制御できるため、アプリケーションの保守性と拡張性が大幅に向上します。

以上がGolang に基づいて開発されたタスクフロー フレームワークを共有するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。