mirrors/phobos
1
0
Fork 0
mirror of https://github.com/dlang/phobos.git synced 2025-04-28 06:00:35 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #1092 from AndrejMitrovic/Fix6224

Browse source 
Issue 6224 - Add ownerTid() property.
This commit is contained in:
Alex Rønne Petersen 2013-03-08 09:53:48 -08:00
commit 9cb2065fe6
1 changed files with 41 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

49
std/concurrency.d
View file

@ -303,6 +303,19 @@ class MailboxFull : Exception
}
/**
* Thrown when a Tid is missing, e.g. when $(D ownerTid) doesn't
* find an owner thread.
*/
class TidMissingException : Exception
{
this(string msg, string file = __FILE__, size_t line = __LINE__)
{
super(msg, file, line);
}
}
//////////////////////////////////////////////////////////////////////////////
// Thread ID
//////////////////////////////////////////////////////////////////////////////
@ -313,14 +326,6 @@ class MailboxFull : Exception
*/
struct Tid
{
void send(T...)( T vals )
{
static assert( !hasLocalAliasing!(T),
"Aliases to mutable thread-local data not allowed." );
_send( this, vals );
}
private:
this( MessageBox m )
{
@ -343,6 +348,34 @@ private:
return Tid( mbox );
}
/**
* Return the Tid of the thread which
* spawned the caller's thread.
*
* Throws: A $(D TidMissingException) exception if
* there is no owner thread.
*/
@property Tid ownerTid()
{
enforceEx!TidMissingException(owner.mbox !is null, "Error: Thread has no owner thread.");
return owner;
}
unittest
{
static void fun()
{
string res = receiveOnly!string();
assert(res == "Main calling");
ownerTid.send("Child responding");
}
assertThrown!TidMissingException(ownerTid);
auto child = spawn(&fun);
child.send("Main calling");
string res = receiveOnly!string();
assert(res == "Child responding");
}
//////////////////////////////////////////////////////////////////////////////
// Thread Creation