[dmd-concurrency] Shutdown protocol

[Sean Kelly]

On Jan 20, 2010, at 3:54 PM, Andrei Alexandrescu wrote:

> Sean Kelly wrote:
>> On Jan 20, 2010, at 11:26 AM, Andrei Alexandrescu wrote:
>>> I don't think so. When the two instances of the copy threads finish reading and sending messages to their writers, they return. As a consequence, wait returns. As a consequence, main finishes.
>>> 
>>> At this critical point, we have the following situation:
>>> 
>>> (a) main has finished, therefore the shutdown mode is in effect
>>> 
>>> (b) There are a number of messages in flight containing buffers waiting to be written in the two files.
>>> 
>>> The important thing to do is to NOT throw shutdown as long as calls to receive() would not block.
>> That sounds like a horrible race problem.
> 
> 
> Not at all. On the contrary, it's the stark opposite of a race:
> 
> * Readers only finish after they have sent all messages they had to send.
> 
> * Application doesn't shutdown until all sent messages have been acted upon.

If the reader is slower than the writer it's entirely possible that the writer will block on receive() during processing.  The receiver really only knows that it's done when it receives a message to that effect from the reader thread. If the threads were linked then this might be a "normal" shutdown message, for example.  Funny now that we're talking about this how many use cases I'm thinking of for bidirectional linking.