TaskDispatcher

Dispatching task Asynchronously or sequentially

create a dispatcher and dispatching a task

std::shared_ptr<AsyncDispatcher> dispatcher = std::shared_ptr<AsyncDispatcher>(new AsyncDispatcher);
  
dispatcher->dispatch([]{
        printf("dispatcher1 is doing a task! \n");
  });

make dispatcher list

  ThreadDispatcher::pushDispatcher
            (std::shared_ptr<AsyncDispatcher>(new AsyncDispatcher));
  
  ThreadDispatcher::peekDispatcher()->dispatch([]{
        printf("dispatcher1 is doing a task!\n");
    });

full exmaple

  #include <iostream>
  #include <functional>
  #include <tr1/memory>
  #include <bitset>
  #include <zconf.h>
  #include "AsyncDispatcher.h"
  #include "ThreadDispatcher.h"

  using namespace std;

  std::string syncTask1(int a){ // calculate binary of int by string in 16 bits
      sleep(2);// simulate time consuming
      return std::bitset<16>(a).to_string();;
  }

  int syncTask2(std::string str){ // calculate the size of a string
      sleep(3);// simulate time consuming
      return str.size();
  }


  std::shared_ptr<AsyncDispatcher> dispatcher = std::shared_ptr<AsyncDispatcher>(new AsyncDispatcher);


  int main() {


    ThreadDispatcher::pushDispatcher
            (std::shared_ptr<AsyncDispatcher>(new AsyncDispatcher));

    dispatcher->dispatch([]{
        printf("dispatcher1  bin of 150 is : %s\n", syncTask1(150).c_str());
    });

    dispatcher->dispatch([]{
        printf("dispatcher1 bin of 200 is: %s\n", syncTask1(150).c_str());
    });

    ThreadDispatcher::peekDispatcher()->dispatch([]{
        printf("dispatcher2 len of 111: %d\n", syncTask2("111"));
    });

    ThreadDispatcher::peekDispatcher()->dispatch([]{
        printf("dispatcher2 len of 222: %d\n", syncTask2("222"));
    });

    ThreadDispatcher::pushDispatcher
            (std::shared_ptr<AsyncDispatcher>(new AsyncDispatcher));

    ThreadDispatcher::peekDispatcher()->dispatch([]{
        printf("dispatcher3 len of 333: %d\n", syncTask2("333"));
    });

    printf("in main thread\n");

    ThreadDispatcher::popDispatcher(); // main thread waits until all tasks of dispatcher 3 to be done!

    printf("in main thread, after removing a dispatcher!\n");

    return 0;
  }

and result is:

  in main thread
  dispatcher1  bin of 150 is : 0000000010010110
  dispatcher2 len of 111: 3
  dispatcher3 len of 333: 3
  in main thread, after removing a dispatcher!
  dispatcher1 bin of 200 is: 0000000010010110
  dispatcher2 len of 222: 3