E:/dev/eLynx/include/elx/core/TaskScheduler.h

//============================================================================
//  TaskScheduler.h                                     Core.Component package
//============================================================================
//  Usage : Timer class.
//----------------------------------------------------------------------------
//  Copyright (C) 2006 by eLynx project
//
//  This library is free software; you can redistribute it and/or
//  modify it under the terms of the GNU Library General Public
//  License as published by the Free Software Foundation; either
//  version 2 of the License, or (at your option) any later version.
//
//  This library is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
//  Library General Public License for more details.
//
//  You should have received a copy of the GNU Library General Public
//  License along with this library; if not, write to the Free
//  Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
//
//----------------------------------------------------------------------------
#ifndef __TaskScheduler_h__
#define __TaskScheduler_h__

#include <elx/core/CoreOS.h>
#include <elx/core/CoreLib.h>

#ifdef elxUSE_THREAD

#include <vector>
#include <boost/function.hpp>
#include <elx/core/CoreTypes.h>

namespace eLynx {
        
class ExportedByCore TaskScheduler
{
public:
  typedef boost::function0<uint32> Task;
  // we should use typedef boost::function<uint32 ()> Task;

  TaskScheduler();
  
  void AddTask(Task iTask);
  
  uint32 Run();

  static uint32 GetCPUCount();

private:
  uint32 RunSingleCore();
  
  uint32 RunMultiCore();
  
  struct CoreTask
  {
    CoreTask(Task iTask, size_t iCPU);

    uint32 operator()();
    
    Task _task;     
    size_t _CPU;    
    uint32 _status; 
  };
  
  const static size_t _nCPU;     
  std::vector<CoreTask> _tasks;  
  size_t _CPU;                   
};

} // namespace eLynx

#else // elxUSE_THREAD

namespace eLynx {
        
class ExportedByCore TaskScheduler
{
public:
  static uint32 GetCPUCount();
};

} // namespace eLynx


#endif //elxUSE_THREAD 

#endif // __TaskScheduler_h__