mirrors/phobos
1
0
Fork 0
mirror of https://github.com/dlang/phobos.git synced 2025-05-02 08:00:48 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Merge pull request #7333 from berni44/issue7446

Browse source 
Fix Issue 7446 - [TDPL] Trivial asynchronous file copy example crashes
merged-on-behalf-of: Nicholas Wilson <thewilsonator@users.noreply.github.com>
This commit is contained in:
The Dlang Bot 2020-01-02 09:20:06 +01:00 • committed by GitHub
commit d0d02596dc
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 37 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

47
std/concurrency.d
View file

@ -673,6 +673,12 @@ in (tid.mbox !is null)
* matched by an earlier delegate. If more than one argument is sent, * matched by an earlier delegate. If more than one argument is sent,
* the `Variant` will contain a $(REF Tuple, std,typecons) of all values * the `Variant` will contain a $(REF Tuple, std,typecons) of all values
* sent. * sent.
*
* Params:
* ops = Variadic list of function pointers and delegates. Entries
* in this list must not occlude later entries.
*
* Throws: $(LREF OwnerTerminated) when the sending thread was terminated.
*/ */
void receive(T...)( T ops ) void receive(T...)( T ops )
in in
@ -769,13 +775,17 @@ private template receiveOnlyRet(T...)
} }
/** /**
* Receives only messages with arguments of types `T`. * Receives only messages with arguments of the specified types.
* *
* Throws: `MessageMismatch` if a message of types other than `T` * Params:
* is received. * T = Variadic list of types to be received.
* *
* Returns: The received message. If `T.length` is greater than one, * Returns: The received message. If `T` has more than one entry,
* the message will be packed into a $(REF Tuple, std,typecons). * the message will be packed into a $(REF Tuple, std,typecons).
*
* Throws: $(LREF MessageMismatch) if a message of types other than `T`
* is received,
* $(LREF OwnerTerminated) when the sending thread was terminated.
*/ */
receiveOnlyRet!(T) receiveOnly(T...)() receiveOnlyRet!(T) receiveOnly(T...)()
in in
@ -869,13 +879,30 @@ do
} }
/** /**
* Tries to receive but will give up if no matches arrive within duration. * Receives a message from another thread and gives up if no match
* Won't wait at all if provided $(REF Duration, core,time) is negative. * arrives within a specified duration.
* *
* Same as `receive` except that rather than wait forever for a message, * Receive a message from another thread, or block until `duration` exceeds,
* it waits until either it receives a message or the given * if no messages of the specified types are available. This function works
* $(REF Duration, core,time) has passed. It returns `true` if it received a * by pattern matching a message against a set of delegates and executing
* message and `false` if it timed out waiting for one. * the first match found.
*
* If a delegate that accepts a $(REF Variant, std,variant) is included as
* the last argument, it will match any message that was not
* matched by an earlier delegate. If more than one argument is sent,
* the `Variant` will contain a $(REF Tuple, std,typecons) of all values
* sent.
*
* Params:
* duration = Duration, how long to wait. If `duration` is negative,
* won't wait at all.
* ops = Variadic list of function pointers and delegates. Entries
* in this list must not occlude later entries.
*
* Returns: `true` if it received a message and `false` if it timed out waiting
* for one.
*
* Throws: $(LREF OwnerTerminated) when the sending thread was terminated.
*/ */
bool receiveTimeout(T...)(Duration duration, T ops) bool receiveTimeout(T...)(Duration duration, T ops)
in in