debian-packages/vibe-core
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Merge pull request #236 from vibe-d/fix_task_interrupt_assertion_failure

Browse source 
Avoid bogus "A task cannot interrupt itself" assertion failure.
This commit is contained in:
Leonid Kramer 2020-11-20 09:53:17 +01:00 committed by GitHub
parent a170973cfd 3182160a9a
commit 983cc15f70
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
source/vibe/core/task.d
View file

@ -97,7 +97,14 @@ struct Task {
void join() @trusted { if (m_fiber) m_fiber.join!true(m_taskCounter); } void join() @trusted { if (m_fiber) m_fiber.join!true(m_taskCounter); }
void joinUninterruptible() @trusted nothrow { if (m_fiber) m_fiber.join!false(m_taskCounter); } void joinUninterruptible() @trusted nothrow { if (m_fiber) m_fiber.join!false(m_taskCounter); }
void interrupt() @trusted nothrow { if (m_fiber) m_fiber.interrupt(m_taskCounter); } void interrupt() @trusted nothrow { if (m_fiber && this.running) m_fiber.interrupt(m_taskCounter); }
unittest { // regression test for bogus "task cannot interrupt itself"
import vibe.core.core : runTask;
auto t = runTask({});
t.join();
runTask({ t.interrupt(); }).join();
}
string toString() const @safe { import std.string; return format("%s:%s", () @trusted { return cast(void*)m_fiber; } (), m_taskCounter); } string toString() const @safe { import std.string; return format("%s:%s", () @trusted { return cast(void*)m_fiber; } (), m_taskCounter); }
@ -138,7 +145,6 @@ struct Task {
} }
} }
/** Settings to control the behavior of newly started tasks. /** Settings to control the behavior of newly started tasks.
*/ */
struct TaskSettings { struct TaskSettings {