job.H

/*
 * This file is part of the "Archon" framework.
 * (http://files3d.sourceforge.net)
 *
 * Copyright © 2002 by Kristian Spangsege and Brian Kristiansen.
 *
 * Permission to use, copy, modify, and distribute this software and
 * its documentation under the terms of the GNU General Public License is
 * hereby granted. No representations are made about the suitability of
 * this software for any purpose. It is provided "as is" without express
 * or implied warranty. See the GNU General Public License
 * (http://www.gnu.org/copyleft/gpl.html) for more details.
 *
 * The characters in this file are ISO8859-1 encoded.
 *
 * The documentation in this file is in "Doxygen" style
 * (http://www.doxygen.org).
 */

#ifndef ARCHON_UTILITIES_JOB_H
#define ARCHON_UTILITIES_JOB_H

#include <string>
#include <queue>
#include <list>
#include <deque>

#include <archon/util/thread.H>

namespace Archon
{
  namespace Utilities
  {
    using namespace std;

    struct Job: virtual RefObjectBase
    {
      Job(): thread(0) {}

      virtual ~Job() {}

      virtual void main() = 0;

      struct Queue
      {
        Queue(int maxThreads = 8, Time maxIdleTime = Time(10.0));

        ~Queue();

        void add(Ref<Job>);

        void cancel(Ref<Job>);

        void wait();

      private:
        const int maxThreads;
        const Time maxIdleTime;

        Mutex mutex;
        Condition newJob;     // Signalled when a new job is added to the queue of pending jobs.
        Condition threadQuit; // Signalled each time a thread quits.
        Condition allDone;    // Signalled when all threads are idle and there is no pending jobs.

        unsigned long nextThreadId;
        list<Ref<Job> > pendingJobs;
        list<unsigned long> idleThreads;
        int activeThreads;
        bool shutdown;

        void worker();
        static void workerEntry(Queue *);
      };

    private:
      Thread *thread;
    };
  }
}

#endif // ARCHON_UTILITIES_JOB_H

---