加入收藏 | 设为首页 | 会员中心 | 我要投稿 武汉站长网 (https://www.027zz.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 站长学院 > PHP教程 > 正文

PHP混合Go协程并发

发布时间:2016-11-05 16:22:26 所属栏目:PHP教程 来源:segmentfault
导读:副标题#e# 想法很简单。通过设置 runtime.GOMAXPROCS(1) 让 golang 的进程变成单线程执行的。类似python用gevent的效果。然后通过调度多个协程实现异步I/O并发。php作为一个子函数跑在go的进程内,php需要yield到其他协程时,通过回调到golang函数来实现。
副标题[/!--empirenews.page--]

PHP混合Go协程并发

想法很简单。通过设置 runtime.GOMAXPROCS(1) 让 golang 的进程变成单线程执行的。类似python用gevent的效果。然后通过调度多个协程实现异步I/O并发。php作为一个子函数跑在go的进程内,php需要yield到其他协程时,通过回调到golang函数来实现。从php里调用go提供的子函数时,go保证保存php的当前上下文。当协程执行权让渡回来的时候,把原来的php上下文恢复。关键的代码在:

  1.  // 保存当前协程上的php上下文    
  2. oldServerCtx := engine.ServerContextGet() 
  3.     fmt.Println(oldServerCtx) 
  4.     defer engine.ServerContextSet(oldServerCtx) 
  5.     oldExecutorCtx := engine.ExecutorContextGet() 
  6.     fmt.Println(oldExecutorCtx) 
  7.     defer engine.ExecutorContextSet(oldExecutorCtx) 
  8.     oldCoreCtx := engine.CoreContextGet() 
  9.     fmt.Println(oldCoreCtx) 
  10.     defer engine.CoreContextSet(oldCoreCtx) 
  11.  
  12. // 放弃全局的锁,使得其他的协程可以开始执行php 
  13.     engineLock.Unlock() 
  14.     defer engineLock.Lock()  

ServerContextGet 这几个函数是我加的,获得的是php的(EG/SG/PG)这三个全局context(参见:http://www.cnblogs.com/chance...)。修改过的github.com/deuill/go-php的源代码在:https://github.com/taowen/go-...

完整的php/go混合协程的demo:

  1. package main 
  2.  
  3. import ( 
  4.     "fmt" 
  5.     "github.com/deuill/go-php/engine" 
  6.     "os" 
  7.     "runtime" 
  8.     "time" 
  9.     "sync" 
  10.  
  11. type TestObj struct{} 
  12.  
  13. func newTestObj(args []interface{}) interface{} { 
  14.     return &TestObj{} 
  15. var engineLock *sync.Mutex 
  16.  
  17. func (self *TestObj) Hello() { 
  18.     oldServerCtx := engine.ServerContextGet() 
  19.     fmt.Println(oldServerCtx) 
  20.     defer engine.ServerContextSet(oldServerCtx) 
  21.     oldExecutorCtx := engine.ExecutorContextGet() 
  22.     fmt.Println(oldExecutorCtx) 
  23.     defer engine.ExecutorContextSet(oldExecutorCtx) 
  24.     oldCoreCtx := engine.CoreContextGet() 
  25.     fmt.Println(oldCoreCtx) 
  26.     defer engine.CoreContextSet(oldCoreCtx) 
  27.     engineLock.Unlock() 
  28.     defer engineLock.Lock() 
  29.     time.Sleep(time.Second) 
  30.     fmt.Println("sleep done") 
  31.  
  32. func main() { 
  33.     runtime.GOMAXPROCS(1) 
  34.     theEngine, err := engine.New() 
  35.     engineLock = &sync.Mutex{} 
  36.     if err != nil { 
  37.         fmt.Println(err) 
  38.     } 
  39.     _, err = theEngine.Define("TestObj", newTestObj) 
  40.     wg := &sync.WaitGroup{} 
  41.     wg.Add(2) 
  42.     before := time.Now() 
  43.     fmt.Println("1") 
  44.     go func() { 
  45.         engineLock.Lock() 
  46.         defer engineLock.Unlock() 
  47.         context1, err := theEngine.NewContext() 
  48.         if err != nil { 
  49.             fmt.Println(err) 
  50.         } 
  51.         context1.Output = os.Stdout 
  52.         if err != nil { 
  53.             fmt.Println(err) 
  54.         } 
  55.         fmt.Println("1 enter") 
  56.         _, err = context1.Eval("$testObj = new TestObj(); $testObj->Hello();") 
  57.         fmt.Println("1 back") 
  58.         if err != nil { 
  59.             fmt.Println(err) 
  60.         } 
  61.         //theEngine.DestroyContext(context1) 
  62.         fmt.Println("1 done") 
  63.         wg.Done() 
  64.     }() 
  65.     fmt.Println("2") 
  66.     go func() { 
  67.         engineLock.Lock() 
  68.         defer engineLock.Unlock() 
  69.         context2, err := theEngine.NewContext() 
  70.         if err != nil { 
  71.             fmt.Println(err) 
  72.         } 
  73.         if err != nil { 
  74.             fmt.Println(err) 
  75.         } 
  76.         context2.Output = os.Stdout 
  77.         fmt.Println("2 enter") 
  78.         _, err = context2.Eval("$testObj = new TestObj(); $testObj->Hello();") 
  79.         fmt.Println("2 back") 
  80.         if err != nil { 
  81.             fmt.Println(err) 
  82.         } 
  83.         //theEngine.DestroyContext(context2) 
  84.         fmt.Println("2 done") 
  85.         wg.Done() 
  86.     }() 
  87.     wg.Wait() 
  88.     after := time.Now() 
  89.     fmt.Println(after.Sub(before)) 
  90. }  

(编辑:武汉站长网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

热点阅读