TaskQueue.h 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  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. public:
  14. explicit TaskQueue(HTML::EventLoop&);
  15. virtual ~TaskQueue() override;
  16. bool is_empty() const { return m_tasks.is_empty(); }
  17. bool has_runnable_tasks() const;
  18. void add(JS::NonnullGCPtr<HTML::Task>);
  19. JS::GCPtr<HTML::Task> take_first_runnable();
  20. void enqueue(JS::NonnullGCPtr<HTML::Task> task) { add(task); }
  21. JS::GCPtr<HTML::Task> dequeue()
  22. {
  23. if (m_tasks.is_empty())
  24. return {};
  25. return m_tasks.take_first();
  26. }
  27. void remove_tasks_matching(NOESCAPE Function<bool(HTML::Task const&)>);
  28. JS::MarkedVector<JS::NonnullGCPtr<Task>> take_tasks_matching(NOESCAPE Function<bool(HTML::Task const&)>);
  29. Task const* last_added_task() const;
  30. private:
  31. virtual void visit_edges(Visitor&) override;
  32. JS::NonnullGCPtr<HTML::EventLoop> m_event_loop;
  33. Vector<JS::NonnullGCPtr<HTML::Task>> m_tasks;
  34. };
  35. }