CSP

Communicating Sequential Processes

Transcript

1. CSP othree
2. Communicating Sequential Processes
3. https://medium.com/@addyosmani/javascript-application-architecture-on-the-road-to-2015-d8125811101b
6. What is CSP • Communication between processes • Born to be async • Using channel
7. Process B Process A
8. Process B Process A Channel msg
9. Process B Process A msg PUT
10. Process B Process A msg
11. Process B Process A msg TAKE
12. Process B Process A Channel msg
13. Implements Go Clojure goroutine core.async
14. https://speakerdeck.com/kachayev/channels-and-concurrency-go-clojure-erlang-haskell
15. Go Example
16. package main import "fmt" func main() { messages := make(chan string, 1) messages <- "ping" msg := <-messages fmt.Println(msg) }
17. package main import "fmt" func main() { messages := make(chan string, 1) messages <- "ping" msg := <-messages fmt.Println(msg) }
18. Short Variable Declarations • Declare variable • and assign value at the same time :=
19. package main import "fmt" func main() { messages := make(chan string, 1) messages <- "ping" msg := <-messages fmt.Println(msg) }
20. Receive Operator • Receive message • From channel • or channel receive message • Also imply direction of message <-
21. package main import "fmt" func main() { messages := make(chan string, 1) messages <- "ping" msg := <-messages fmt.Println(msg) }
23. Go Example II
24. package main import "fmt" import "time" func worker(done chan bool) { fmt.Print("working...") time.Sleep(time.Second) fmt.Println("done") done <- true } func main() { done := make(chan bool, 1) go worker(done) <-done }
25. package main import "fmt" import "time" func worker(done chan bool) { fmt.Print("working...") time.Sleep(time.Second) fmt.Println("done") done <- true } func main() { done := make(chan bool, 1) go worker(done) <-done }
26. package main import "fmt" import "time" func worker(done chan bool) { fmt.Print("working...") time.Sleep(time.Second) fmt.Println("done") done <- true } func main() { done := make(chan bool, 1) go worker(done) <-done }
27. Go Statement • Execute function as independent process(goroutine) go
29. Go Pingpong Example
30. package main import "fmt" import "time" type Ball struct{ hits int } func player(name string, table chan *Ball) { for { ball := <-table ball.hits++ fmt.Println(name, ball.hits) time.Sleep(100 * time.Millisecond) table <- ball } }
31. package main import "fmt" import "time" type Ball struct{ hits int } func player(name string, table chan *Ball) { for { ball := <-table ball.hits++ fmt.Println(name, ball.hits) time.Sleep(100 * time.Millisecond) table <- ball } }
32. player • Receive ball from channel • Hit ball(+1) • Sleep • Send ball back
33. func main() { table := make(chan *Ball) go player("ping", table) go player("pong", table) table <- new(Ball) // game on; toss the ball time.Sleep(1 * time.Second) <-table // game over; grab the ball }
34. func main() { table := make(chan *Ball) go player("ping", table) go player("pong", table) table <- new(Ball) // game on; toss the ball time.Sleep(1 * time.Second) <-table // game over; grab the ball }
35. func main() { table := make(chan *Ball) go player("ping", table) go player("pong", table) table <- new(Ball) // game on; toss the ball time.Sleep(1 * time.Second) <-table // game over; grab the ball }
36. func main() { table := make(chan *Ball) go player("ping", table) go player("pong", table) table <- new(Ball) // game on; toss the ball time.Sleep(1 * time.Second) <-table // game over; grab the ball }
37. Process Channel Message players table Ball
38. player pong player ping table Ball
40. Key Requirement • Channel • Ability to wait(idle) message
41. Channel • First class object • First in first out • Accessible across processes
42. Idle • Not able to idle in JavaScript • Use recursive function call can emulate, bad performance • ES6 have async function
43. async function
44. function* foo(){ var index = 0; while (index <= 2) // when index reaches 3, // yield's done will be true // and its value will be undefined; yield index++; }
45. var iterator = foo(); console.log(iterator.next()); // { value:0, done:false } console.log(iterator.next()); // { value:1, done:false } console.log(iterator.next()); // { value:2, done:false } console.log(iterator.next()); // { value:undefined, done:true }
46. yield • Function will stop and return on yield • Next call will exec from last yield • Sort of idle
47. js-csp
48. js-csp • by Nguyễn Tuấn Anh • Major implementation • Use async function • Also implement `go`, dispatcher…etc
50. Pingpong Example
51. function* player(name, table) { while (true) { var ball = yield csp.take(table); if (ball === csp.CLOSED) { console.log(name + ": table's gone"); return; } ball.hits += 1; console.log(name + " " + ball.hits); yield csp.timeout(100); yield csp.put(table, ball); } }
52. function* player(name, table) { while (true) { var ball = yield csp.take(table); if (ball === csp.CLOSED) { console.log(name + ": table's gone"); return; } ball.hits += 1; console.log(name + " " + ball.hits); yield csp.timeout(100); yield csp.put(table, ball); } } func player(name string, table chan *Ball) { for { ball := <-table ball.hits++ fmt.Println(name, ball.hits) time.Sleep(100 * time.Millisecond) table <- ball } } Go
53. csp.go(function* () { var table = csp.chan(); csp.go(player, ["ping", table]); csp.go(player, ["pong", table]); yield csp.put(table, {hits: 0}); yield csp.timeout(1000); table.close(); });
54. csp.go(function* () { var table = csp.chan(); csp.go(player, ["ping", table]); csp.go(player, ["pong", table]); yield csp.put(table, {hits: 0}); yield csp.timeout(1000); table.close(); }); func main() { table := make(chan *Ball) go player("ping", table) go player("pong", table) table <- new(Ball) time.Sleep(1 * time.Second) <-table } Go
55. csp.go(player, ["ping", table]); go player("ping", table) yield csp.put(table, {hits: 0}); table <- new(Ball) yield csp.take(table); <-table
56. csp.go(function* () { func main() { var table = csp.chan(); table := make(chan *Ball) yield csp.timeout(1000); time.Sleep(1 * time.Second)
57. js-csp • Easy to port Go program • yield is annoying
58. What Can Use CSP • Sequential async data • Event
59. Real World Event • Might have multiple event handler on single event
60. Channel Message • Only can take once
61. operations alt mult mix merge onto pipe split close timeout https://clojure.github.io/core.async/
62. mult • one to many
63. var csp = require("./src/csp"); var mult = csp.operations.mult; var buffers = csp.buffers; var channel = csp.chan(); var m = mult(channel); https://github.com/ubolonton/js-csp/issues/31#issuecomment-68089526
64. var csp = require("./src/csp"); var mult = csp.operations.mult; var buffers = csp.buffers; var channel = csp.chan(); var m = mult(channel);
65. csp.go(function*() { var out = mult.tap(m, csp.chan(buffers.sliding(1))); var val = yield csp.take(out); console.log('process 1', val); }); csp.go(function*() { var out = mult.tap(m, csp.chan(buffers.sliding(1))); var val = yield csp.take(out); console.log('process 2', val); });
66. csp.go(function*() { var out = mult.tap(m, csp.chan(buffers.sliding(1))); var val = yield csp.take(out); console.log('process 1', val); }); csp.go(function*() { var out = mult.tap(m, csp.chan(buffers.sliding(1))); var val = yield csp.take(out); console.log('process 2', val); });
67. csp.go(function*() { var out = mult.tap(m, csp.chan(buffers.sliding(1))); var val = yield csp.take(out); console.log('process 1', val); }); csp.go(function*() { var out = mult.tap(m, csp.chan(buffers.sliding(1))); var val = yield csp.take(out); console.log('process 2', val); });
68. csp.putAsync(channel, 42);
69. not stable on js-csp
70. Cons • Annoying yield • Not stable operations* • Lib size • Not support Web Worker
71. js-csp • Syntax from Go • Operations from Clojure • Have disadvantages • Can use transducer from Clojure
72. https://www.youtube.com/watch?v=7rDsRXj9-cU