Skip to content

Instantly share code, notes, and snippets.

@cstockton

cstockton/pltr-onering.md

Created May 3, 2018 04:16
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save cstockton/08628ab142634b46f080d01b5e595172 to your computer and use it in GitHub Desktop.
Save cstockton/08628ab142634b46f080d01b5e595172 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
pltr-onering.md 
.../github.com/pltr$ mkdir $GOPATH/src/github.com/pltr
.../github.com/pltr$ cd $GOPATH/src/github.com/pltr
.../github.com/pltr$ git clone git@github.com:pltr/onering.git
Cloning into 'onering'...
remote: Counting objects: 251, done.
remote: Compressing objects: 100% (155/155), done.
remote: Total 251 (delta 158), reused 186 (delta 94), pack-reused 0
Receiving objects: 100% (251/251), 40.88 KiB | 0 bytes/s, done.
Resolving deltas: 100% (158/158), done.
Checking connectivity... done.
.../github.com/pltr$ cd onering
.../pltr/onering$ go test -bench . -race
goos: linux
goarch: amd64
pkg: github.com/pltr/onering
BenchmarkRingSPSC_Get-24        	 1000000	      1435 ns/op
BenchmarkRingSPSC_Consume-24    	 1000000	      1708 ns/op
BenchmarkRingSPMC-24            	  300000	      4215 ns/op
BenchmarkRingMPSC_Get-24        	  300000	      9790 ns/op
BenchmarkRingMPSC_Batch-24      	==================
WARNING: DATA RACE
Write at 0x00c4202dac10 by goroutine 151:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dac10 by goroutine 59:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 151 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 59 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dacc8 by goroutine 79:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dacc8 by goroutine 59:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 79 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 59 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dace0 by goroutine 99:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dace0 by goroutine 73:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 99 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 73 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dac18 by goroutine 189:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dac18 by goroutine 90:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 189 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 90 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dab50 by goroutine 125:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dab50 by goroutine 162:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 125 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 162 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202daaa8 by goroutine 98:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202daaa8 by goroutine 123:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 98 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 123 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202daa98 by goroutine 188:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202daa98 by goroutine 36:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 188 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 36 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dab58 by goroutine 139:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dab58 by goroutine 142:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 139 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 142 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202daae0 by goroutine 65:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202daae0 by goroutine 142:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 65 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 142 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dacd0 by goroutine 68:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dacd0 by goroutine 114:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 68 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 114 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dab30 by goroutine 56:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dab30 by goroutine 36:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 56 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 36 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202daaf8 by goroutine 156:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202daaf8 by goroutine 101:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 156 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 101 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dabf8 by goroutine 122:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dabf8 by goroutine 73:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 122 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 73 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dac88 by goroutine 64:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dac88 by goroutine 36:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 64 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 36 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202daba8 by goroutine 119:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202daba8 by goroutine 73:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 119 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 73 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dab38 by goroutine 95:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dab38 by goroutine 97:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 95 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 97 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dac28 by goroutine 183:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dac28 by goroutine 97:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 183 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 97 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dacf8 by goroutine 89:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dacf8 by goroutine 83:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 89 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 83 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dacd8 by goroutine 155:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dacd8 by goroutine 142:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 155 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 142 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dab28 by goroutine 153:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dab28 by goroutine 171:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 153 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 171 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dad10 by goroutine 137:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dad10 by goroutine 101:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 137 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 101 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202daa78 by goroutine 45:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202daa78 by goroutine 36:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 45 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 36 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c4202dad18 by goroutine 173:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Previous write at 0x00c4202dad18 by goroutine 131:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 173 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 131 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Read at 0x00c4202df630 by goroutine 35:
  github.com/pltr/onering.(*MPSC).Consume()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:47 +0x141
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func2()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:160 +0xad

Previous write at 0x00c4202df630 by goroutine 95:
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:60 +0x153
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 35 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:158 +0x37d
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 95 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
==================
WARNING: DATA RACE
Write at 0x00c420249630 by goroutine 35:
  github.com/pltr/onering.(*MPSC).Consume()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:48 +0x16b
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func2()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:160 +0xad

Previous write at 0x00c420249630 by goroutine 95:
  sync/atomic.StoreInt64()
      /ws/lang/go/src/runtime/race_amd64.s:234 +0xb
  github.com/pltr/onering.(*MPSC).Put()
      /ws/cws/src/github.com/pltr/onering/mpsc.go:61 +0x1cf
  github.com/pltr/onering.BenchmarkRingMPSC_Batch.func1()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:153 +0xbc

Goroutine 35 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:158 +0x37d
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2

Goroutine 95 (running) created at:
  github.com/pltr/onering.BenchmarkRingMPSC_Batch()
      /ws/cws/src/github.com/pltr/onering/ring_test.go:149 +0x317
  testing.(*B).runN()
      /ws/lang/go/src/testing/benchmark.go:141 +0x127
  testing.(*B).launch()
      /ws/lang/go/src/testing/benchmark.go:290 +0xb2
==================
--- FAIL: BenchmarkRingMPSC_Batch-24
	benchmark.go:147: race detected during execution of benchmark
BenchmarkRingMPMC_Get-24        	  300000	      3583 ns/op
BenchmarkChanMPMC-24            	  200000	      6562 ns/op
BenchmarkChan/SPSC-24           	  200000	      5455 ns/op
BenchmarkChan/SPMC-64-24        	  200000	      7303 ns/op
BenchmarkChan/MPSC-64-24        	  200000	      7323 ns/op
FAIL
exit status 1
FAIL	github.com/pltr/onering	16.576s
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment