#pragma once
#include "DFGPlan.h"
#include "DFGThreadData.h"
#include <wtf/AutomaticThread.h>
#include <wtf/Condition.h>
#include <wtf/Deque.h>
#include <wtf/HashMap.h>
#include <wtf/Lock.h>
namespace JSC {
class SlotVisitor;
namespace DFG {
#if ENABLE(DFG_JIT)
class Worklist : public RefCounted<Worklist> {
public:
enum State { NotKnown, Compiling, Compiled };
~Worklist();
static Ref<Worklist> create(CString worklistName, unsigned numberOfThreads, int relativePriority = 0);
void enqueue(Ref<Plan>&&);
void completeAllPlansForVM(VM&);
template<typename Func>
void iterateCodeBlocksForGC(VM&, const Func&);
void waitUntilAllPlansForVMAreReady(VM&);
State completeAllReadyPlansForVM(VM&, CompilationKey = CompilationKey());
void removeAllReadyPlansForVM(VM&);
State compilationState(CompilationKey);
size_t queueLength();
void suspendAllThreads();
void resumeAllThreads();
bool isActiveForVM(VM&) const;
void visitWeakReferences(SlotVisitor&);
void removeDeadPlans(VM&);
void removeNonCompilingPlansForVM(VM&);
void dump(PrintStream&) const;
private:
Worklist(CString worklistName);
void finishCreation(unsigned numberOfThreads, int);
class ThreadBody;
friend class ThreadBody;
void runThread(ThreadData*);
static void threadFunction(void* argument);
void removeAllReadyPlansForVM(VM&, Vector<RefPtr<Plan>, 8>&);
void dump(const AbstractLocker&, PrintStream&) const;
CString m_threadName;
Deque<RefPtr<Plan>> m_queue;
typedef HashMap<CompilationKey, RefPtr<Plan>> PlanMap;
PlanMap m_plans;
Vector<RefPtr<Plan>, 16> m_readyPlans;
Lock m_suspensionLock;
Box<Lock> m_lock;
RefPtr<AutomaticThreadCondition> m_planEnqueued;
Condition m_planCompiled;
Vector<std::unique_ptr<ThreadData>> m_threads;
unsigned m_numberOfActiveThreads;
};
Worklist& ensureGlobalDFGWorklist();
Worklist* existingGlobalDFGWorklistOrNull();
Worklist& ensureGlobalFTLWorklist();
Worklist* existingGlobalFTLWorklistOrNull();
Worklist& ensureGlobalWorklistFor(CompilationMode);
unsigned numberOfWorklists();
Worklist& ensureWorklistForIndex(unsigned index);
Worklist* existingWorklistForIndexOrNull(unsigned index);
Worklist& existingWorklistForIndex(unsigned index);
#endif // ENABLE(DFG_JIT)
void completeAllPlansForVM(VM&);
void markCodeBlocks(VM&, SlotVisitor&);
template<typename Func>
void iterateCodeBlocksForGC(VM&, const Func&);
} }