//
//  main.cpp
//  dispatch
//
//  Created by Max on 30.06.13.
//  Copyright (c) 2013 Max Lunin. All rights reserved.
//

#include "dispatch.h"

#include <assert.h>
#include <iostream>
#include <sstream>
#include <string>
#include <thread>

int main(int argc, const char * argv[])
{
    auto main_thread_id = std::this_thread::get_id();
    
    for (unsigned task = 0; task < 6; ++task)
    for (unsigned priority = 0; priority < 6; ++priority)
    {
        dispatch::queue(priority).async([=]
        {
            assert(std::this_thread::get_id() != main_thread_id);
            
            std::string task_string = std::to_string(task);
            
            std::string palceholder(1+priority*5, ' ');
            
            dispatch::queue::main_queue()->async([=]
            {
                assert(std::this_thread::get_id() == main_thread_id);
                
                std::cout << palceholder << task_string << std::endl;
            });
        });
    }

    dispatch::queue(dispatch::QUEUE_PRIORITY::BACKGROUND).async([]
    {
        std::chrono::milliseconds timespan(1); // or whatever
        std::this_thread::sleep_for(timespan);
        std::cout << "exit" << std::endl;
        dispatch::exit();
    });

    dispatch::main_loop([]{
        std::cout << ".";
    });
    
    return 0;
}