Is go-disruptor support many producer?

[smarty-prototypes]

Is go-disruptor support many producer?

[ankisme]

The way I use it cause data race.

=== RUN   TestGoDisruptorMultipleProducer
==================
WARNING: DATA RACE
Read at 0x00c000070560 by goroutine 9:
  github.com/smartystreets-prototypes/go-disruptor.(*DefaultWriter).Reserve()
      D:/proj/mine/gopath/pkg/mod/github.com/smartystreets-prototypes/[email protected]/default_writer.go:28 +0x5c
  web/business/taskqueuepackage/test_test.publish()
      D:/proj/mine/gopath/src/gitee-server/business/taskqueuepackage/test/GoDisruptorMultipleProducer_test.go:29 +0xc6

Previous write at 0x00c000070560 by goroutine 8:
  github.com/smartystreets-prototypes/go-disruptor.(*DefaultWriter).Reserve()
      D:/proj/mine/gopath/pkg/mod/github.com/smartystreets-prototypes/[email protected]/default_writer.go:28 +0x78
  web/business/taskqueuepackage/test_test.publish()
      D:/proj/mine/gopath/src/gitee-server/business/taskqueuepackage/test/GoDisruptorMultipleProducer_test.go:29 +0xc6

Goroutine 9 (running) created at:
  web/business/taskqueuepackage/test_test.TestGoDisruptorMultipleProducer()
      D:/proj/mine/gopath/src/gitee-server/business/taskqueuepackage/test/GoDisruptorMultipleProducer_test.go:21 +0x18c
  testing.tRunner()
      D:/go/src/testing/testing.go:909 +0x1a0

Goroutine 8 (running) created at:
  web/business/taskqueuepackage/test_test.TestGoDisruptorMultipleProducer()
      D:/proj/mine/gopath/src/gitee-server/business/taskqueuepackage/test/GoDisruptorMultipleProducer_test.go:21 +0x18c
  testing.tRunner()
      D:/go/src/testing/testing.go:909 +0x1a0
==================
==================
WARNING: DATA RACE
Read at 0x00c000070568 by goroutine 9:
  github.com/smartystreets-prototypes/go-disruptor.(*DefaultWriter).Reserve()
      D:/proj/mine/gopath/pkg/mod/github.com/smartystreets-prototypes/[email protected]/default_writer.go:29 +0x137
  web/business/taskqueuepackage/test_test.publish()
      D:/proj/mine/gopath/src/gitee-server/business/taskqueuepackage/test/GoDisruptorMultipleProducer_test.go:29 +0xc6

Previous write at 0x00c000070568 by goroutine 8:
  github.com/smartystreets-prototypes/go-disruptor.(*DefaultWriter).Reserve()
      D:/proj/mine/gopath/pkg/mod/github.com/smartystreets-prototypes/[email protected]/default_writer.go:34 +0xce
  web/business/taskqueuepackage/test_test.publish()
      D:/proj/mine/gopath/src/gitee-server/business/taskqueuepackage/test/GoDisruptorMultipleProducer_test.go:29 +0xc6

Goroutine 9 (running) created at:
  web/business/taskqueuepackage/test_test.TestGoDisruptorMultipleProducer()
      D:/proj/mine/gopath/src/gitee-server/business/taskqueuepackage/test/GoDisruptorMultipleProducer_test.go:21 +0x18c
  testing.tRunner()
      D:/go/src/testing/testing.go:909 +0x1a0

Goroutine 8 (running) created at:
  web/business/taskqueuepackage/test_test.TestGoDisruptorMultipleProducer()
      D:/proj/mine/gopath/src/gitee-server/business/taskqueuepackage/test/GoDisruptorMultipleProducer_test.go:21 +0x18c
  testing.tRunner()
      D:/go/src/testing/testing.go:909 +0x1a0

And the DefaultWriter seems should be used in only a goroutine?

func (this *DefaultWriter) Reserve(count int64) int64 {
	if count <= 0 {
		panic(ErrMinimumReservationSize)
	}

	this.previous += count
	for spin := int64(0); this.previous-this.capacity > this.gate; spin++ {
		if spin&SpinMask == 0 {
			runtime.Gosched() // LockSupport.parkNanos(1L); http://bit.ly/1xiDINZ
		}

		this.gate = this.upstream.Load()
	}
	return this.previous
}

[joliver]

Right now it only supports a single producer.

If you want to do multiple producers, the only workaround is to do:

mutex.Lock()
// claim
// write
mutex.Unlock()