Shulou(Shulou.com)06/02 Report--

This article mainly introduces "PHP mixed Go program concurrency analysis". In daily operation, I believe many people have doubts about PHP mixed Go program concurrency analysis. The editor consulted all kinds of data and sorted out simple and easy-to-use operation methods. I hope it will be helpful to answer the doubts of "PHP mixed Go program concurrency analysis". Next, please follow the editor to study!

The idea is simple. Make the golang process single-threaded by setting runtime.GOMAXPROCS (1). Similar to the effect of python with gevent. Then by scheduling multiple coprograms to achieve asynchronous Igamot O concurrency. Php runs in the process of go as a subfunction. When php needs to yield to other co-programs, it is realized by calling back to the golang function. When a subfunction provided by go is called from php, go guarantees that the current context of the php is saved. When the execution power of the co-process is transferred back, the original php context is restored. The key code is:

/ / Save the php context on the current protocol oldServerCtx: = engine.ServerContextGet () fmt.Println (oldServerCtx) defer engine.ServerContextSet (oldServerCtx) oldExecutorCtx: = engine.ExecutorContextGet () fmt.Println (oldExecutorCtx) defer engine.ExecutorContextSet (oldExecutorCtx) oldCoreCtx: = engine.CoreContextGet () fmt.Println (oldCoreCtx) defer engine.CoreContextSet (oldCoreCtx) / / discard the global lock So that other collaborators can start executing php engineLock.Unlock () defer engineLock.Lock ()

I added these functions ServerContextGet, and I got the three global context of php (EG/SG/PG).

The demo of the complete php/go hybrid protocol:

Package main import ("fmt"github.com/deuill/go-php/engine"os"runtime"time"sync") type TestObj struct {} func newTestObj (args [] interface {}) interface {} {return & TestObj {} var engineLock * sync.Mutex func (self * TestObj) Hello () {oldServerCtx: = engine.ServerContextGet () fmt.Println (oldServerCtx) Defer engine.ServerContextSet (oldServerCtx) oldExecutorCtx: = engine.ExecutorContextGet () fmt.Println (oldExecutorCtx) defer engine.ExecutorContextSet (oldExecutorCtx) oldCoreCtx: = engine.CoreContextGet () fmt.Println (oldCoreCtx) defer engine.CoreContextSet (oldCoreCtx) engineLock.Unlock () defer engineLock.Lock () time.Sleep (time.Second) fmt.Println ("sleep done")} func main () {runtime.GOMAXPROCS (1) theEngine Err: = engine.New () engineLock = & sync.Mutex {} if err! = nil {fmt.Println (err)} _, err = theEngine.Define ("TestObj", newTestObj) wg: = & sync.WaitGroup {} wg.Add (2) before: = time.Now () fmt.Println ("1") go func () {engineLock.Lock () defer engineLock.Unlock () context1 Err: = theEngine.NewContext () if err! = nil {fmt.Println (err)} context1.Output = os.Stdout if err! = nil {fmt.Println (err)} fmt.Println ("1 enter") _, err = context1.Eval ("$testObj = new TestObj () $testObj- > Hello () ") fmt.Println (" 1 back ") if err! = nil {fmt.Println (err)} / / theEngine.DestroyContext (context1) fmt.Println (" 1 done ") wg.Done ()} () fmt.Println (" 2 ") go func () {engineLock.Lock () defer engineLock.Unlock () context2 Err: = theEngine.NewContext () if err! = nil {fmt.Println (err)} if err! = nil {fmt.Println (err)} context2.Output = os.Stdout fmt.Println ("2 enter") _, err = context2.Eval ("$testObj = new TestObj () $testObj- > Hello (); ") fmt.Println (" 2 back ") if err! = nil {fmt.Println (err)} / / theEngine.DestroyContext (context2) fmt.Println (" 2 done ") wg.Done ()} () wg.Wait () after: = time.Now () fmt.Println (after.Sub (before))}

The result of execution is

1 2 2 enter {0x2cf2930 {000 0 [000 00] 00 1000 [000 0]} {{0 16 0x7f682e819780 0 [000 000 0]} 0 1 [000]} 000 [000 000] {000 000 000 00 {00} {00} {00} [000]} 0x2a00270 0x2a00f60 8388608 0 1 [000] 0 { 8 7 2 [0 0 0] 0 0x29f4520 0x29f4520 0x29f4470 0x29f4420 1 0 0 [0 0 0]} {0 [0 0 0]} 0 [0 0 0]} {0x7ffd30bac588 {[0 0 0] 20 0 [0 0]} 0x7f682f01b928 {[0 0 0] 1 0 0 [0 0]} 0x7f682f01b948 [ ] 0x7f682f01ba60 0x7f682f01b960 0x7f682f167168 0x7f682f01ba88 {64 63 5 [00 00] 0 0x7f682f1972d8 0x7f682f1972d8 0x7f682f1993f8 0x7f682f1970c8 0x7f682e862d10 00 1 [00 00 0]} {80 0 [00 00] 0 0x7f682f016a00 00 1 [00 00 0]} 0x7ffd30bac590 22527 00 [00 00] 0x7f682f197640 0x29f4f80 0x29f4fd0 0x29f5070 0x2cf2950 0x7f682f1989c0 140 1 [00 0] 01 [00 00 00] {80 0 [00 00] 1 0x7f682f016a00 0x7f682e883140 00 1 [00 00]} {8 00 [00] 0 0x7f682f016a00 0x7f682e8831d0 100 [00 0]} 0x7f682f167088 0 [00] {00} {00 [00 00]} {00 [00 00]} 0 [00] 00 0x29fb2e0 {0x7f682f187030 2 1024-1 [00]} [{0x7f682e915050 [00 00] [0 0 0 0] [0 0 0] 0 0 149 8 8 8} {0x7f682e915050 [0 0 0] [0 0 0] [0 0 0] 0 0 149 8 8 8} {0x7f682e915050 [0 0 0] [0 0 0] [0 0 0] 0 0 149 8 8 8}] 0x7f682f167168 {0 [0 0 0 ] 0 [00 00] 00 [00 00] 0 [00 00]} 1 [00 00] 0x7f682f01bde8 895 [00 00] []} {1 [00 00 0] 00 [00] 0x29ff9a0 17 134217728-10 001 [00] 1024 001 [00] 0x2a00870 0x2a010a0 0x7f682ecc58b0 0x7f682ecc5c23 2097152 0x2a00180 0x2a00230 {0x7f682ec91aa8 0x7f682ec91aa8} 0x2a00910 {0 0 0 [0 0 0] 0 0 0 [0 0 0]} 0 0 0 [0 0 0] {0x2b6dc10 0x2b6dc10 1 8 1 [0 0 0]} [0x7f682f197330 0x7f682f197040 0x7f682f197410 0x7f682f1974f0] 0 1 1 [0 0 0] 0x7f682ec9544b 0x7f682ec9544b 0 0 [0 0 0] 0 [0 0 0] 1 1 1 10 1 [0] 0 [0 0 0] 0 [0 0 0] 0x2cf27c0 0 0 [ 000 000] 64 1000 0 [000 000 0] 0x7f682ecc6270 300 0x2a009b0 1 [000 000 0] 0 [000 000 0]} 1 enter {0x7f6818000aa0 {000 0 [000 00] 00 1000 [000 0]} {{0 16 0x7f682e819780 0 [000 000 0]} 0 1 [000]} 000 [000 000] {00 00 00 00 0 {00} {00} {00} [00 0]} 0x2a00270 0x2a00f60 8388608 0 1 [00 0] 0 {8 7 2 [00 00] 0 0x29f4520 0x29f4520 0x29f4470 0x29f4420 1 00 [00 00 0]} {0 [00 00 00 0]} 0 [00 00 00 0]} {0x7f682a4cccd8 {[00 00 00] 20 0 [0 0]} 0x7f682f01b928 {[00 00 00] 10 0 [00]} 0x7f682f01b948 [] 0x7f682f01ba60 0x7f682f01b960 0x7f682802f110 0x7f682f01ba88 {64 63 5 [00 00] 0 0x7f682f197a00 0x7f682f197a00 0x7f682f198368 0x7f682f198fa0 0x7f682e862d10 00 1 [00 00 0]} {80 0 [00 00] 0 0x7f682f016a00 00 1 [00 00 0]} 0x7f682a4ccce0 22527 00 [00 00] 0x7f682f197d28 0x29f4f80 0x29f4fd0 0x29f5070 0x2cf2950 0x7f682f1983e8 140 1 [00 0] 01 [00 00 00] {80 0 [00 00] 1 0x7f682f016a00 0x7f682e883140 00 1 [00 00 0]} {80 0 [00 00] 0 0x7f682f016a00 0x7f682e8831d0 1 00 [00 00 0]} 0x7f682802f030 0 [00 00] {00} {00 0 [00 00 00 0]} {00 0 [00 00 00 0]} 0 0 0x29fb2e0 {0x7f682804efd8 2 1024-1 [0 000]} [{0x7f682e915050 [0 000 0 0 0 000 0 0 0 149 8 8 8] {0x7f682e915050 [0 0 000 0 0 0 000 0 0 0 149 8 8} {0x7f682e915050 [0 0 000 0 0] 0 0 149 8 8} {0x7f682e915050 0 0] [0 0 0] [0 0 0] 0 0 149 8 8 8}] 0x7f682802f110 {0 [0 0 0] 0 [0 0 0] 0 0 [0 0 0] 0 [0 0 0]} 1 [0 0 0] 0x7f682f01bde8 895 [0 0 0] []} {1 [0 0 0] 0 0 0 [0 0 0] 0x29ff9a0 17 134217728-10 001 [00 00] 1024 001 [00] 0x2a00870 0x2a010a0 0x7f682ecc58b0 0x7f682ecc5c23 2097152 0x2a00180 0x2a00230 {0x7f682ec91aa8 0x7f682ec91aa8} 0x2a00910 {00 0 [00 00] 00 [00]} 00 [00] {0x2b6dc10 0x2b6dc10 18 1 [00 00]} [0x7f682f197a58 0x7f682f198ce0 0x7f682f197b38 0x7f682f197c18] 01 [00 0] 0x7f682ec9544b 0x7f682ec9544b 00 [00 0 0] 0 [000 000 00] 11 11 10 1 [0] 0 [000 0] 0 [000 0] 0x2cf27c0 00 [000 000] 64 1000 0 [000 000 0] 0x7f682ecc6270 300 0x2a009b0 1 [000 000 0] 0 [000 000 0]} sleep done 1 back 1 done sleep done 2 back 2 done 1.00099211s

You can see two sleep 1s, which ended up using only 1.00099211s. It shows that the collaborative process is concurrent.

Some performance metrics. Use http to call the backend. On i7-6700k, you can get such a result with ab-n 100-c 4.

Requests per second: 3183.70 [# / sec] (mean) Time per request: 1.256 [ms] (mean) Time per request: 0.314 [ms] (mean, across all concurrent requests)

If you do not use http to call the backend, and directly php= > go returns "hello", you can achieve

Requests per second: 10073.54 [# / sec] (mean) Time per request: 0.397 [ms] (mean) Time per request: 0.099 [ms] (mean, across all concurrent requests)

These indicators only indicate the cost of collaborative switching. The actual benefit depends on the latency of the back-end http service, and if it takes a long time, the benefit can be significant through collaborative concurrency.

This experiment shows that golang can be used to implement an application server instead of nginx+php-fpm. It also provides a smooth migration path from php to golang. Mix PHP and Go in one application.

And the asynchronization of Imax O can be realized by providing golang function to php call. Extensions like libcurl itself support asynchronous callbacks, but php is synchronous so only synchronous execute is exposed to php. With Golang, you can turn execute into a wrapper for asynchronous execute+callback, thus achieving co-program-based scheduling.

At this point, the study of "PHP mixed Go protocol concurrency analysis" is over. I hope to be able to solve everyone's doubts. The collocation of theory and practice can better help you learn, go and try it! If you want to continue to learn more related knowledge, please continue to follow the website, the editor will continue to work hard to bring you more practical articles!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.