首页 > Golang > Go教程
Go语言context test源码分析详情

来源：脚本之家
时间：2023-02-24 16:44:58 472浏览收藏
来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《Go语言context test源码分析详情》，介绍一下test、语言context、源码，希望对大家的知识积累有所帮助，助力实战开发！
1.测试例子分析

example_test.go,展示了With-系列的4个例子
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
func ExampleWithCancel() {
  gen := func(ctx context.Context) 
<p>结构分析,<code>gen</code>是一个函数,返回值是一个信道, <code>for range channel</code>是有特殊意义的, for会循环从channel读数据,直到channel被close(),不然就是无限循环.</p>
<p>gen内部的协程就是典型的闭包,for range会不断触发读,gen内部的for select 会不断触发写,主协程读5次之后,会结束main函数,会触发defer函数, 也就是取消操作对应的回调,此时done信道会被close,gen内部的协程会正常退出.</p>
<p>这个例子是测试支持取消信号的上下文,取消函数的调用放在了<code>main</code>的<code>defer</code>函数中.</p>
<pre class="brush:bash;">const shortDuration = 1 * time.Millisecond
func ExampleWithDeadline() {
  d := time.Now().Add(shortDuration)
  ctx, cancel := context.WithDeadline(context.Background(), d)
 
  // 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.
  defer cancel()
 
  select {
  case
<p><code>deadline</code>的这个例子,在<code>main</code>的<code>defer</code>中也有主动调用取消函数的. 实际上通过打印可以显示deadline是否按预期工作.</p>
<pre class="brush:bash;">func ExampleWithTimeout() {
  ctx, cancel := context.WithTimeout(context.Background(), shortDuration)
  defer cancel()
 
  select {
  case
<p><code>timeout</code>只是<code>deadline</code>的一种简写.</p>
<pre class="brush:bash;">func ExampleWithValue() {
  type favContextKey string
 
  f := func(ctx context.Context, k favContextKey) {
    if v := ctx.Value(k); v != nil {
      fmt.Println("found value:", v)
      return
    }
    fmt.Println("key not found:", k)
  }
 
  k := favContextKey("language")
  ctx := context.WithValue(context.Background(), k, "Go")
 
  f(ctx, k)
  f(ctx, favContextKey("color"))
 
  // Output:
  // found value: Go
  // key not found: color
}</pre>
<p><code>context.WithValue</code>和<code>Context.Value()</code>是存取操作, 取的时候,如果key没找到,会返回nil.</p>
<h2>2.单元测试</h2>
<p><code>context_text.go,x_test.go</code>是单元测试, ex<code>ample_test.go</code>是示例,benchmark_test.go是基准测试, net_test.go展示了deadline对net包的支持.</p>
<p><strong>先看单元测试的context_text.go.</strong></p>
<pre class="brush:bash;">type testingT interface {}
 
type otherContext struct {}
func quiescent(t testingT) time.Duration {}
func XTestBackground(t testingT) {}
func XTestTODO(t testingT) {}
func XTestWithCancel(t testingT) {}
func contains(m map[canceler]struct{}, key canceler) bool {}
func XTestParentFinishesChild(t testingT) {}
func XTestChildFinishesFirst(t testingT) {}
func testDeadline(c Context, name string, t testingT) {}
func XTestDeadline(t testingT) {}
func XTestTimeout(t testingT) {}
func XTestCanceledTimeout(t testingT) {}
func XTestValues(t testingT) {}
func XTestAllocs(t testingT, testingShort func() bool, testingAllocsPerRun func(int, func()) float64) {}
func XTestSimultaneousCancels(t testingT) {}
func XTestInterlockedCancels(t testingT) {}
func XTestLayersCancel(t testingT) {}
func XTestLayersTimeout(t testingT) {}
func XTestCancelRemoves(t testingT) {}
func XTestWithCancelCanceledParent(t testingT) {}
func XTestWithValueChecksKey(t testingT) {}
func XTestInvalidDerivedFail(t testingT) {}
func recoveredValue(fn func()) (v interface{}) {}
func XTestDeadlineExceededSupportsTimeout(t testingT) {}
type myCtx struct {}
type myDoneCtx struct {}
func (d *myDoneCtx) Done() 
<p>这暴露的大多测试函数的参数类型是testingT接口类型,但这个源文件中没有实现<code>testingT</code>接口的,</p>
<pre class="brush:bash;">func TestBackground(t *testing.T)                      { XTestBackground(t) }
func TestTODO(t *testing.T)                            { XTestTODO(t) }
func TestWithCancel(t *testing.T)                      { XTestWithCancel(t) }
func TestParentFinishesChild(t *testing.T)             { XTestParentFinishesChild(t) }
func TestChildFinishesFirst(t *testing.T)              { XTestChildFinishesFirst(t) }
func TestDeadline(t *testing.T)                        { XTestDeadline(t) }
func TestTimeout(t *testing.T)                         { XTestTimeout(t) }
func TestCanceledTimeout(t *testing.T)                 { XTestCanceledTimeout(t) }
func TestValues(t *testing.T)                          { XTestValues(t) }
func TestAllocs(t *testing.T)                          { XTestAllocs(t, testing.Short, testing.AllocsPerRun) }
func TestSimultaneousCancels(t *testing.T)             { XTestSimultaneousCancels(t) }
func TestInterlockedCancels(t *testing.T)              { XTestInterlockedCancels(t) }
func TestLayersCancel(t *testing.T)                    { XTestLayersCancel(t) }
func TestLayersTimeout(t *testing.T)                   { XTestLayersTimeout(t) }
func TestCancelRemoves(t *testing.T)                   { XTestCancelRemoves(t) }
func TestWithCancelCanceledParent(t *testing.T)        { XTestWithCancelCanceledParent(t) }
func TestWithValueChecksKey(t *testing.T)              { XTestWithValueChecksKey(t) }
func TestInvalidDerivedFail(t *testing.T)              { XTestInvalidDerivedFail(t) }
func TestDeadlineExceededSupportsTimeout(t *testing.T) { XTestDeadlineExceededSupportsTimeout(t) }
func TestCustomContextGoroutines(t *testing.T)         { XTestCustomContextGoroutines(t) }</pre>
<p>这是<code>x_test.go</code>的内容,直接是用<code>testing.T</code>类型来实现testingT接口.</p>
<p><strong>那先分析一下testing.T对testingT接口的实现.</strong></p>
<pre class="brush:bash;">type T struct {
  common
  isParallel bool
  context    *testContext
}
func (t *T) Deadline() (deadline time.Time, ok bool) {
  deadline = t.context.deadline
  return deadline, !deadline.IsZero()
}</pre>
<blockquote><p><strong>注意：</strong>testing.T.context不是context.Context的实现类型, Deadline()返回了t.context中存储的deadline信息.</p></blockquote>
<p><strong>testing.T内嵌了testing.common,大部分方法集都来至common:</strong></p>
<pre class="brush:bash;">Error(args ...interface{})
Errorf(format string, args ...interface{})
Fail()
FailNow()
Failed() bool
Fatal(args ...interface{})
Fatalf(format string, args ...interface{})
Helper()
Log(args ...interface{})
Logf(format string, args ...interface{})
Name() string
Skip(args ...interface{})
SkipNow()
Skipf(format string, args ...interface{})
Skipped() bool</pre>
<p><code>Parallel()</code>是由<code>testing.T</code>实现,某个测试用例多次重复执行时, 可启用并发参数.</p>
<p>今天关于《Go语言context test源码分析详情》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！</p></pre></pre></pre>
golang test 语言context 源码
声明：本文转载于：脚本之家如有侵犯，请联系study_golang@163.com删除