mirror of
https://gitee.com/johng/gf.git
synced 2024-12-04 21:28:22 +08:00
35 lines
946 B
Go
35 lines
946 B
Go
// 多进程通信示例，
|
||
// 子进程每个1秒向父进程发送当前时间，
|
||
// 父进程监听进程消息，收到后打印到终端。
|
||
package main
|
||
|
||
import (
|
||
"os"
|
||
"fmt"
|
||
"time"
|
||
"gitee.com/johng/gf/g/os/gproc"
|
||
"gitee.com/johng/gf/g/os/gtime"
|
||
"gitee.com/johng/gf/g/os/glog"
|
||
)
|
||
|
||
func main () {
|
||
fmt.Printf("%d: I am child? %v\n", gproc.Pid(), gproc.IsChild())
|
||
if gproc.IsChild() {
|
||
gtime.SetInterval(time.Second, func() bool {
|
||
if err := gproc.Send(gproc.PPid(), []byte(gtime.Datetime())); err != nil {
|
||
glog.Error(err)
|
||
}
|
||
return true
|
||
})
|
||
select { }
|
||
} else {
|
||
m := gproc.NewManager()
|
||
p := m.NewProcess(os.Args[0], os.Args, os.Environ())
|
||
p.Start()
|
||
for {
|
||
msg := gproc.Receive()
|
||
fmt.Printf("%d: receive from %d, data: %s\n", gproc.Pid(), msg.Pid, string(msg.Data))
|
||
}
|
||
}
|
||
}
|