diff options
Diffstat (limited to 'Source/WebCore/dom/Microtasks.h')
-rw-r--r-- | Source/WebCore/dom/Microtasks.h | 74 |
1 files changed, 74 insertions, 0 deletions
diff --git a/Source/WebCore/dom/Microtasks.h b/Source/WebCore/dom/Microtasks.h new file mode 100644 index 000000000..c6a083868 --- /dev/null +++ b/Source/WebCore/dom/Microtasks.h @@ -0,0 +1,74 @@ +/* + * Copyright (C) 2014 Yoav Weiss (yoav@yoav.ws) + * Copyright (C) 2015 Akamai Technologies Inc. All rights reserved. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Library General Public + * License as published by the Free Software Foundation; either + * version 2 of the License, or (at your option) any later version. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Library General Public License for more details. + * + * You should have received a copy of the GNU Library General Public License + * along with this library; see the file COPYING.LIB. If not, write to + * the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, + * Boston, MA 02110-1301, USA. + * + */ + +#pragma once + +#include "Timer.h" +#include <wtf/NeverDestroyed.h> +#include <wtf/Vector.h> + +namespace WebCore { + +class MicrotaskQueue; + +class Microtask { +public: + virtual ~Microtask() + { + } + + enum class Result { + Done, + KeepInQueue + }; + + virtual Result run() = 0; + +protected: + void removeSelfFromQueue(MicrotaskQueue&); +}; + +class MicrotaskQueue { + friend NeverDestroyed<MicrotaskQueue>; + friend class Microtask; +public: + WEBCORE_EXPORT static MicrotaskQueue& mainThreadQueue(); + + WEBCORE_EXPORT MicrotaskQueue(); + WEBCORE_EXPORT ~MicrotaskQueue(); + + WEBCORE_EXPORT void append(std::unique_ptr<Microtask>&&); + WEBCORE_EXPORT void performMicrotaskCheckpoint(); + +private: + WEBCORE_EXPORT void remove(const Microtask&); + + void timerFired(); + + bool m_performingMicrotaskCheckpoint = false; + Vector<std::unique_ptr<Microtask>> m_microtaskQueue; + + // FIXME: Instead of a Timer, we should have a centralized Event Loop that calls performMicrotaskCheckpoint() + // on every iteration, implementing https://html.spec.whatwg.org/multipage/webappapis.html#processing-model-9 + Timer m_timer; +}; + +} // namespace WebCore |