pagent是一个多进程模型的golang库,具有以下特点:

简单: 父子进程只通过stdin和stdout来交互

安全: 多进程很安全,子进程挂掉一个不影响其他子进程

解耦:子进程交互和业务分离

例子:

package main

import (

    "fmt"

    "time"

    "github.com/adwpc/pagent"

)

type MyBiz struct {

    pagent.Master

}

func NewBiz() *MyBiz {

    return &MyBiz{}

}

func (a *MyBiz) BizRunning(id, str string) error {

    fmt.Println("[MyBiz BizRunning] str=" + str)

    return nil

}

func (a *MyBiz) BizFinish(id string, err error) error {

    fmt.Println("[MyBiz BizFinish] id=" + id)

    return err

}

func main() {

    a := NewBiz()

    fmt.Println("worker1-------------------------")

    a.GetWorker("worker1").Start("bash", a.BizRunning, a.BizFinish)

    a.GetWorker("worker1").Input("ls")

    time.Sleep(1 * time.Second)

    a.DelWorker("worker1")

    fmt.Println("worker2-------------------------")

    a.GetWorker("worker2").Start("ifconfig", nil, a.BizFinish)

    time.Sleep(1 * time.Second)

    a.DelWorker("worker2")

    fmt.Printf("end!----------------------------")

}