JobQueue.hh

Go to the documentation of this file.

 
#ifndef PythonMonkey_JobQueue_
#define PythonMonkey_JobQueue_
 
#include <jsapi.h>
#include <js/Promise.h>
 
#include <Python.h>
 
class JobQueue : public JS::JobQueue {
 
public:
explicit JobQueue(JSContext *cx);
~JobQueue() = default;
 
bool init(JSContext *cx);
 
JSObject *getIncumbentGlobal(JSContext *cx) override;
 
bool enqueuePromiseJob(JSContext *cx, JS::HandleObject promise,
  JS::HandleObject job, JS::HandleObject allocationSite,
  JS::HandleObject incumbentGlobal) override;
 
void runJobs(JSContext *cx) override;
 
bool empty() const override;
 
bool isDrainingStopped() const override;
 
void queueFinalizationRegistryCallback(JSFunction *callback);
 
bool runFinalizationRegistryCallbacks(JSContext *cx);
 
private:
 
using FunctionVector = JS::GCVector<JSFunction *, 0, js::SystemAllocPolicy>;
JS::PersistentRooted<FunctionVector> *finalizationRegistryCallbacks;
 
js::UniquePtr<JS::JobQueue::SavedJobQueue> saveJobQueue(JSContext *) override;
 
static bool dispatchToEventLoop(void *closure, JS::Dispatchable *dispatchable);
 
static void promiseRejectionTracker(JSContext *cx, bool mutedErrors,
  JS::HandleObject promise, JS::PromiseRejectionHandlingState state,
  void *privateData);
 
}; // class
 
bool sendJobToMainLoop(PyObject *pyFunc);
 
#endif