1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
|
# Context
This module defines the Context type, which carries deadlines, cancellation signals,
and other request-scoped values across API boundaries and between processes.
Incoming requests to a server should create a Context, and outgoing calls to servers
should accept a Context. The chain of function calls between them must propagate the
Context, optionally replacing it with a derived Context created using with_cancel,
with_deadline, with_timeout, or with_value. When a Context is canceled, all Contexts
derived from it are also canceled.
The with_cancel, with_deadline, and with_timeout functions take a Context (the parent)
and return a derived Context (the child). Calling the cancel function
cancels the child and its children, removes the parent's reference to the child,
and stops any associated timers.
Programs that use Contexts should follow these rules to keep interfaces consistent
across different modules.
Do not store Contexts inside a struct type; instead, pass a Context explicitly
to each function that needs it. The Context should be the first parameter,
typically named ctx, just to make it more consistent.
## Examples
In this section you can see some usage examples for this module
### Context With Cancellation
```v
import context
// This example demonstrates the use of a cancelable context to prevent a
// routine leak. By the end of the example function, the routine started
// by gen will return without leaking.
fn example_with_cancel() {
// gen generates integers in a separate routine and
// sends them to the returned channel.
// The callers of gen need to cancel the context once
// they are done consuming generated integers not to leak
// the internal routine started by gen.
gen := fn (ctx context.Context) chan int {
dst := chan int{}
go fn (ctx context.Context, dst chan int) {
mut v := 0
ch := ctx.done()
for {
select {
_ := <-ch {
// returning not to leak the routine
return
}
dst <- v {
v++
}
}
}
}(ctx, dst)
return dst
}
ctx := context.with_cancel(context.background())
defer {
context.cancel(ctx)
}
ch := gen(ctx)
for i in 0 .. 5 {
v := <-ch
assert i == v
}
}
```
### Context With Deadline
```v
import context
import time
const (
// a reasonable duration to block in an example
short_duration = 1 * time.millisecond
)
// This example passes a context with an arbitrary deadline to tell a blocking
// function that it should abandon its work as soon as it gets to it.
fn example_with_deadline() {
dur := time.now().add(short_duration)
ctx := context.with_deadline(context.background(), dur)
defer {
// Even though ctx will be expired, it is good practice to call its
// cancellation function in any case. Failure to do so may keep the
// context and its parent alive longer than necessary.
context.cancel(ctx)
}
ctx_ch := ctx.done()
select {
_ := <-ctx_ch {}
1 * time.second {
panic('This should not happen')
}
}
}
```
### Context With Timeout
```v
import context
import time
const (
// a reasonable duration to block in an example
short_duration = 1 * time.millisecond
)
// This example passes a context with a timeout to tell a blocking function that
// it should abandon its work after the timeout elapses.
fn example_with_timeout() {
// Pass a context with a timeout to tell a blocking function that it
// should abandon its work after the timeout elapses.
ctx := context.with_timeout(context.background(), short_duration)
defer {
context.cancel(ctx)
}
ctx_ch := ctx.done()
select {
_ := <-ctx_ch {}
1 * time.second {
panic('This should not happen')
}
}
}
```
### Context With Value
```v
import context
type ValueContextKey = string
// This example demonstrates how a value can be passed to the context
// and also how to retrieve it if it exists.
fn example_with_value() {
f := fn (ctx context.Context, key ValueContextKey) string {
if value := ctx.value(key) {
if !isnil(value) {
return *(&string(value))
}
}
return 'key not found'
}
key := ValueContextKey('language')
value := 'VAL'
ctx := context.with_value(context.background(), key, &value)
assert value == f(ctx, key)
assert 'key not found' == f(ctx, ValueContextKey('color'))
}
```
|
