summaryrefslogtreecommitdiffstats
path: root/dom/media/mediasource/AutoTaskQueue.h
diff options
context:
space:
mode:
Diffstat (limited to 'dom/media/mediasource/AutoTaskQueue.h')
-rw-r--r--dom/media/mediasource/AutoTaskQueue.h59
1 files changed, 59 insertions, 0 deletions
diff --git a/dom/media/mediasource/AutoTaskQueue.h b/dom/media/mediasource/AutoTaskQueue.h
new file mode 100644
index 000000000..1726ad5be
--- /dev/null
+++ b/dom/media/mediasource/AutoTaskQueue.h
@@ -0,0 +1,59 @@
+/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
+/* vim: set ts=8 sts=2 et sw=2 tw=80: */
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+#ifndef MOZILLA_AUTOTASKQUEUE_H_
+#define MOZILLA_AUTOTASKQUEUE_H_
+
+#include "mozilla/RefPtr.h"
+#include "mozilla/SharedThreadPool.h"
+#include "mozilla/TaskQueue.h"
+
+namespace mozilla {
+
+// A convenience TaskQueue not requiring explicit shutdown.
+class AutoTaskQueue : public AbstractThread
+{
+public:
+ explicit AutoTaskQueue(already_AddRefed<SharedThreadPool> aPool, bool aSupportsTailDispatch = false)
+ : AbstractThread(aSupportsTailDispatch)
+ , mTaskQueue(new TaskQueue(Move(aPool), aSupportsTailDispatch))
+ {}
+
+ TaskDispatcher& TailDispatcher() override
+ {
+ return mTaskQueue->TailDispatcher();
+ }
+
+ void Dispatch(already_AddRefed<nsIRunnable> aRunnable,
+ DispatchFailureHandling aFailureHandling = AssertDispatchSuccess,
+ DispatchReason aReason = NormalDispatch) override
+ {
+ mTaskQueue->Dispatch(Move(aRunnable), aFailureHandling, aReason);
+ }
+
+ // Blocks until all tasks finish executing.
+ void AwaitIdle() { mTaskQueue->AwaitIdle(); }
+
+ bool IsEmpty() { return mTaskQueue->IsEmpty(); }
+
+ // Returns true if the current thread is currently running a Runnable in
+ // the task queue.
+ bool IsCurrentThreadIn() override { return mTaskQueue->IsCurrentThreadIn(); }
+
+private:
+ ~AutoTaskQueue()
+ {
+ RefPtr<TaskQueue> taskqueue = mTaskQueue;
+ nsCOMPtr<nsIRunnable> task =
+ NS_NewRunnableFunction([taskqueue]() { taskqueue->BeginShutdown(); });
+ AbstractThread::MainThread()->Dispatch(task.forget());
+ }
+ RefPtr<TaskQueue> mTaskQueue;
+};
+
+} // namespace mozilla
+
+#endif