JobHandler 클래스 참조

#include <JobHandler.h>

JobHandler에 대한 상속 다이어그램 :

Public 멤버 함수
void	HandleJob_Async (CallbackType &&callback)
template<typename T , typename Ret , typename... Args>
void	HandleJob_Async (Ret(T::*method)(Args...), Args... args)

Private 타입
using	JobRef = Job*

Private 멤버 함수
void	executablePush (JobRef job)

Private 속성
uint32	m_AtomicJobCnt
LockFreeQueue< JobRef >	m_AllocatedJobs

멤버 타입정의 문서화

JobRef

using JobHandler::JobRef = Job*

private

멤버 함수 문서화

HandleJob_Async() [1/2]

void JobHandler::HandleJob_Async ( CallbackType && callback )

inline

                                                  {
        auto job = new Job(std::move(callback));
        executablePush(job);
    }

HandleJob_Async() [2/2]

template<typename T , typename Ret , typename... Args>

void JobHandler::HandleJob_Async ( Ret(T::* method )(Args...), Args... args )

inline

    {
        std::shared_ptr<T> owner = std::static_pointer_cast<T>(shared_from_this());
        auto job = new Job(owner, method, std::forward<Args>(args)...);
        executablePush(job);
    }

executablePush()

void JobHandler::executablePush ( JobRef job )

private

{
    // Push
    //const auto ret = InterlockedIncrement(&m_AtomicJobCnt);
    //m_AllocatedJobs.Enqueue(job);
    //if (ret > 1)  return;
    // => JobCnt를 증가하지만 Job Enqueue 전 다른 스레드가 Dequeue를 시도하면,
    //    Dequeue에 실패하여 어떠한 스레드도 Job을 수행하지 못하는 현상 발생 가능
 
    // Push
    m_AllocatedJobs.Enqueue(job);
    if (InterlockedIncrement(&m_AtomicJobCnt) > 1)  return;
 
    // Execute
    while (true) {
        JobRef job;
        if (!m_AllocatedJobs.Dequeue(job)) {
            DebugBreak();
        }
 
        job->Execute();
        if (InterlockedDecrement(&m_AtomicJobCnt) == 0) {
            return;
        }
    }
}

멤버 데이터 문서화

m_AtomicJobCnt

uint32 JobHandler::m_AtomicJobCnt

private

m_AllocatedJobs

LockFreeQueue<JobRef> JobHandler::m_AllocatedJobs

private

---

이 클래스에 대한 문서화 페이지는 다음의 파일들로부터 생성되었습니다.:

• include/JobHandler.h
• JNetCore/JobHandler.cpp