Kongsi rangka kerja Aliran Tugas yang dibangunkan berdasarkan Golang

Go ialah bahasa pengaturcaraan popular yang terkenal dengan kecekapan, kesederhanaan dan kebolehlanjutan yang mudah. Pada masa yang sama, ia juga merupakan bahasa yang sesuai untuk pengaturcaraan serentak dengan mekanisme Goroutine dan Salurannya menjadikan pengaturcaraan serentak sangat mudah. Dalam artikel ini, saya akan memperkenalkan rangka kerja Aliran Tugas yang dibangunkan berdasarkan Golang Di bawah rangka kerja ini, kita boleh menulis proses tugasan dengan sangat mudah. Di bawah, saya akan memperkenalkan secara ringkas penggunaannya:

API Aliran Tugas

Terdapat tiga API penting dalam rangka kerja Aliran Tugas, iaitu:

1. NewTaskflow(): Digunakan untuk mengisytiharkan proses tugas baharu.
2. AddTask(): digunakan untuk menambah tugasan baharu pada proses tugasan. Kaedah ini biasanya memerlukan tiga parameter: nama tugas, kod tugas dan fungsi pelaksanaan tugas.
3. Start(): digunakan untuk memulakan proses tugasan.

Mari kita lihat contoh paling mudah:

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()
}

Melalui contoh di atas kita dapat melihat bahawa kita mula-mula mengisytiharkan proses tugasan baharu, dan kemudian menambah tugas bernama " hello" akhirnya memulakan proses tugasan. Dalam kod tugas, kami hanya mengeluarkan mesej. Jalankan atur cara dan outputnya ialah:

Hello, Taskflow

Walaupun contoh ini mudah, ia memberi kita pemahaman asas tentang konsep dan penggunaan Aliran Tugas.

Tugas dalam Aliran Tugas

Dalam Aliran Tugas, setiap Tugasan ialah unit pelaksanaan bebas dan tugasan itu boleh dilaksanakan satu demi satu dalam susunan yang telah ditetapkan. Setiap Tugas mempunyai nama unik dan kod pelaksanaan. Dalam kod pelaksanaannya, Tugas boleh mengakses objek Aliran Tugas, supaya ia boleh mengetahui status pelaksanaan Tugas lain dan kod yang memanggil Tugas lain. Seterusnya, mari kita lihat cara menggunakan Aliran Tugas untuk membina proses tugasan yang mudah.

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()
}

Dalam kod di atas, kami menggunakan tiga Tugasan dan menambahkannya mengikut tertib. Dalam kod pelaksanaan setiap Tugasan, kami mengeluarkan nama Tugasan.

Kawalan proses tugasan

Dalam proses tugas Aliran Tugas, kami juga boleh menyesuaikan jujukan pelaksanaan tugas dan kesalingbergantungan mereka dengan mengawal pemacu antara tugas. Ini boleh dicapai melalui kaedah Pautan dalam Aliran Tugas. Kaedah Pautan menerima dua parameter: nama Tugas sumber dan nama Tugas sasaran. Sebagai contoh, dalam coretan kod berikut, Task2 dan Task3 ditambahkan sebagai tindakan pasca mereka selepas Task1 selesai:

...
// 启动任务流程
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()
...

Dalam kod ini, kami menambah Tugasan baharu (Task4) dan Gunakan kaedah Pautan sebagai pasca operasi selepas Tugas1. Oleh itu, selepas Tugas1 selesai, Tugas4 akan dilaksanakan sepenuhnya secara selari. Kami juga memautkan Task2 dan Task3 selepas Task4 untuk memastikan ia bermula serta-merta selepas Task4 dilaksanakan.

Ringkasan

Artikel ini memperkenalkan rangka kerja Aliran Tugas dan penggunaannya yang mudah. Walaupun API yang disediakan oleh Taskflow adalah sangat mudah dan praktikal, ia sudah cukup untuk membantu kami menyelesaikan kebanyakan operasi proses tugasan. Dalam aplikasi praktikal, Taskflow boleh membantu kami mentakrifkan dan mengawal proses tugas dengan mudah, dengan itu meningkatkan kebolehselenggaraan dan kebolehskalaan aplikasi dengan sangat baik.

Atas ialah kandungan terperinci Kongsi rangka kerja Aliran Tugas yang dibangunkan berdasarkan Golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!