Add Disruptor.Wait, and Reader.Wait

smarty-prototypes / go-disruptor

A port of the LMAX Disruptor to the Go language.

Apache License 2.0

1.37k stars 212 forks source link

Add Disruptor.Wait, and Reader.Wait #1

Closed paulbellamy closed 5 years ago

paulbellamy commented 9 years ago

Allows users to wait for a disruptor to finish processing all current requests before exiting.

ianzapolsky commented 8 years ago

Newcomer to this project here. Was easy to set up and understand, so props to @joliver for the great work. But, after hooking disruptor into my project, I immediately realized that I needed this feature. So it's awesome that it's been implemented (ty paul). Just expressing my +1 for an expedient merge so i don't have to maintain a patch!

joliver commented 5 years ago

I have updated the model to implement a blocking call to Listen and then another process will call Close which will signal the various readers (listeners) to conclude the work and then exit.