mailbox

package

v0.0.0-...-199659d Latest Latest Go to latest Published: Jun 3, 2017 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Dispatcher interface {
	Schedule(fn func())
	Throughput() int
}

func NewDispatcher(throughput int) Dispatcher

type Invoker interface {
	//优先调用的命令消息
	ReceiveCmdMessage(message interface{})
	//普通传递的消息
	ReceiveUserMessage(message interface{})
}

type Mailbox interface {
	PostUserMessage(message interface{})
	PostCmdMessage(message interface{})
}

The Mailbox interface is used to enqueue messages to the mailbox

func New(size uint64, invoker Invoker, dispatcher Dispatcher) Mailbox

type Queue struct {
	// contains filtered or unexported fields
}

func (q *Queue) Pop() interface{}

Pop get interface{} from queue This call will easy blocked, if the queue is empty ,when multi goroutines

func (q *Queue) Post(item interface{})