cocos2d-x-extensions/ActionQueue.cpp at master · oke-ya/cocos2d-x-extensions · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
//
//  ActionQueue.cpp
//  まじょのおしごと
//
//  Created by Atsushi Yoshida on 2015/03/06.
//
//

#include "ActionQueue.h"

ActionQueue* ActionQueue::getInstance()
{
    static ActionQueue s_instance;
    return &s_instance;
}

void ActionQueue::add(Node* pNode, FiniteTimeAction* pAction)
{
    auto pSeq = Sequence::createWithTwoActions(pAction, CallFunc::create([&](){ run(); }));
    pSeq->retain();
    _queue.push(std::make_tuple(pNode, pSeq));
}

void ActionQueue::add(Node* pNode, Actions& arrayOfActions)
{
    arrayOfActions.pushBack(CallFunc::create([&](){ run(); }));
    auto pSeq = Sequence::create(arrayOfActions);
    if(pNode){
        pSeq->retain();
        _queue.push(std::make_tuple(pNode, pSeq));
    }
}


void ActionQueue::add(std::tuple<Node*, FiniteTimeAction*> tuple)
{
    _queue.push(tuple);
}

void ActionQueue::run()
{
    if(_queue.size() > 0){
        auto t = _queue.front();
        Node* pNode = std::get<0>(t);
        pNode->resume();
        auto pAction = std::get<1>(t);
        pNode->runAction(pAction);
        pAction->release();
        _queue.pop();
    }
}

void ActionQueue::add(Node* pNode, ActionThread& thread)
{
    auto& last = thread.back();
    thread.pop_back();
    auto n = std::get<0>(last);
    auto a = std::get<1>(last);
    n->release();
    a->release();
    thread.add(n, Sequence::create(a, CallFunc::create([&](){ run(); }), nullptr));

    add(pNode, CallFunc::create([&, thread](){
        for(auto& exp: thread){
            auto& node = std::get<0>(exp);
            auto& action = std::get<1>(exp);
            node->runAction(action);
            action->release();
            node->release();
        }
    }));
}

void ActionThread::add(Node* pNode, FiniteTimeAction* pAction)
{
    pNode->retain();
    pAction->retain();
    push_back(std::make_tuple(pNode, pAction));
}