RGBCube/serenity
1
Fork 0
mirror of https://github.com/RGBCube/serenity synced 2025-07-26 11:17:44 +00:00
Code Issues Activity Actions

LibThreading: Add ability to cancel ongoing BackgroundActions

Browse source 
Handlers of the BackgroundAction are responsible for checking if the
action has been cancelled and returning early.
This commit is contained in:
Spencer Dixon 2021-07-02 10:34:19 -04:00 • committed by Andreas Kling
parent 4a3958c8ae
commit 00f93b2545
4 changed files with 18 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

19
Userland/Libraries/LibThreading/BackgroundAction.h
View file

@ -39,16 +39,26 @@ class BackgroundAction final : public Core::Object
public:
static NonnullRefPtr<BackgroundAction<Result>> create(
Function<Result()> action,
Function<Result(BackgroundAction&)> action,
Function<void(Result)> on_complete = nullptr)
{
return adopt_ref(*new BackgroundAction(move(action), move(on_complete)));
}
void cancel()
{
m_cancelled = true;
}
bool is_cancelled() const
{
return m_cancelled;
}
virtual ~BackgroundAction() { }
private:
BackgroundAction(Function<Result()> action, Function<void(Result)> on_complete)
BackgroundAction(Function<Result(BackgroundAction&)> action, Function<void(Result)> on_complete)
: Core::Object(&background_thread())
, m_action(move(action))
, m_on_complete(move(on_complete))
@ -56,7 +66,7 @@ private:
Locker locker(all_actions().lock());
all_actions().resource().enqueue([this] {
m_result = m_action();
m_result = m_action(*this);
if (m_on_complete) {
Core::EventLoop::current().post_event(*this, make<Core::DeferredInvocationEvent>([this](auto&) {
m_on_complete(m_result.release_value());
@ -69,7 +79,8 @@ private:
});
}
Function<Result()> m_action;
bool m_cancelled { false };
Function<Result(BackgroundAction&)> m_action;
Function<void(Result)> m_on_complete;
Optional<Result> m_result;
};