TaskQueue.h 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. /*
  2. * Copyright (c) 2021-2024, Andreas Kling <kling@serenityos.org>
  3. *
  4. * SPDX-License-Identifier: BSD-2-Clause
  5. */
  6. #pragma once
  7. #include <AK/Queue.h>
  8. #include <LibJS/Heap/Cell.h>
  9. #include <LibWeb/HTML/EventLoop/Task.h>
  10. namespace Web::HTML {
  11. class TaskQueue : public JS::Cell {
  12. JS_CELL(TaskQueue, Cell);
  13. JS_DECLARE_ALLOCATOR(TaskQueue);
  14. public:
  15. explicit TaskQueue(HTML::EventLoop&);
  16. virtual ~TaskQueue() override;
  17. bool is_empty() const { return m_tasks.is_empty(); }
  18. bool has_runnable_tasks() const;
  19. void add(JS::NonnullGCPtr<HTML::Task>);
  20. JS::GCPtr<HTML::Task> take_first_runnable();
  21. void enqueue(JS::NonnullGCPtr<HTML::Task> task) { add(task); }
  22. JS::GCPtr<HTML::Task> dequeue()
  23. {
  24. if (m_tasks.is_empty())
  25. return {};
  26. return m_tasks.take_first();
  27. }
  28. void remove_tasks_matching(NOESCAPE Function<bool(HTML::Task const&)>);
  29. JS::MarkedVector<JS::NonnullGCPtr<Task>> take_tasks_matching(NOESCAPE Function<bool(HTML::Task const&)>);
  30. Task const* last_added_task() const;
  31. private:
  32. virtual void visit_edges(Visitor&) override;
  33. JS::NonnullGCPtr<HTML::EventLoop> m_event_loop;
  34. Vector<JS::NonnullGCPtr<HTML::Task>> m_tasks;
  35. };
  36. }