Worker.h

#ifndef TOKENWIZARD_WORKER_H
#define TOKENWIZARD_WORKER_H

#include <thread>
#include <queue>
#include "BaseHeader.h"
#include "TokenRecord.h"
#include "InvalidateTask.h"

using namespace boost::asio;

class Worker {
    boost::asio::io_service::work* gcWork;

    boost::posix_time::seconds interval;
    boost::asio::deadline_timer* timer;
    time_t currTime;
    void gcTick() {
        currTime = time(0);
        size_t currSize = removeQueue.size();
        for(size_t i = 0; i < currSize; ++i) {
            InvalidateTask<TOKEN_LENGTH>& task = removeQueue.front();
            if(task.deleteTime < currTime)
                removeQueue.pop();
            else
                break;
        }
        timer->expires_at(timer->expires_at() + interval);
        timer->async_wait(std::bind(&Worker::gcTick, this));
    }
public:
    void pushRemoveTask(TokenString<TOKEN_LENGTH>* tokenString, size_t lifeTime) {
        removeQueue.emplace(tokenString, lifeTime);
    }
    queue<InvalidateTask<TOKEN_LENGTH>> removeQueue;
    io_service* workerService;
    Worker(): interval(1) {
        currTime = time(0);
        workerService = new io_service();
        gcWork = new io_service::work(*workerService);
        timer = new deadline_timer(*workerService, interval);
        timer->async_wait(std::bind(&Worker::gcTick, this));
        thread([this]() {
            workerService->run();
        }).detach();
    }
};


#endif //TOKENWIZARD_WORKER_H