| 1 | import time |
| 2 | |
| 3 | struct St { |
| 4 | mut: |
| 5 | a int |
| 6 | } |
| 7 | |
| 8 | fn f(shared x St, shared y St, shared z St) { |
| 9 | for _ in 0 .. 101 { |
| 10 | lock x, y { |
| 11 | tmp := y.a |
| 12 | y.a = x.a |
| 13 | x.a = tmp |
| 14 | } |
| 15 | } |
| 16 | lock z { |
| 17 | z.a-- |
| 18 | } |
| 19 | } |
| 20 | |
| 21 | fn test_shared_lock() { |
| 22 | shared x := St{ |
| 23 | a: 5 |
| 24 | } |
| 25 | shared y := &St{ |
| 26 | a: 7 |
| 27 | } |
| 28 | shared z := St{ |
| 29 | a: 1 |
| 30 | } |
| 31 | spawn f(shared x, shared y, shared z) |
| 32 | for _ in 0 .. 100 { |
| 33 | lock x, y { |
| 34 | tmp := x.a |
| 35 | x.a = y.a |
| 36 | y.a = tmp |
| 37 | } |
| 38 | } |
| 39 | // the following would be a good application for a channel |
| 40 | for finished := false; true; { |
| 41 | rlock z { |
| 42 | finished = z.a == 0 |
| 43 | } |
| 44 | if finished { |
| 45 | break |
| 46 | } |
| 47 | time.sleep(100 * time.millisecond) |
| 48 | } |
| 49 | rlock x, y { |
| 50 | assert x.a == 7 && y.a == 5 |
| 51 | } |
| 52 | } |
| 53 | |
| 54 | struct App { |
| 55 | id string = 'test' |
| 56 | mut: |
| 57 | app_data shared AppData |
| 58 | } |
| 59 | |
| 60 | fn (mut a App) init_server_direct() { |
| 61 | lock a.app_data { |
| 62 | // a.app_data = AppData{} |
| 63 | } |
| 64 | } |
| 65 | |
| 66 | struct AppData { |
| 67 | id string = 'foo' |
| 68 | } |
| 69 | |
| 70 | fn test_shared_field_init() { |
| 71 | mut app1 := App{} |
| 72 | app1.init_server_direct() |
| 73 | id := rlock app1.app_data { |
| 74 | app1.app_data.id |
| 75 | } |
| 76 | // assert id == 'foo' |
| 77 | } |
| 78 | |