import std.stdio;
import std.concurrency;
import core.thread;
import std.conv;
void workerFunc(Tid tid) {
Thread.sleep(dur!(msecs)( 500 ),);
tid.send(hello);
}
void main() {
spawn(&workerFunc,thisTid);
writeln(Waiting for a message);
bool received = false;
while (!received) {
received = receiveTimeout(dur!(msecs)( 100 ), (string message) {
writeln(received: , message);
});
if (!received) {
writeln(... no message yet);
}
}
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。