U++

	if(jobs.GetCount()){

		jobThreadActive = true;

		Thread::Start(callback(this, &SkylarkApp::JobThread));

	}

	jobThreadActive = false;

#include "Skylark.h"

namespace Upp {

SkylarkApp& SkylarkApp::AddJob(Callback cb, int period)

{

	ASSERT(!jobThreadActive);

	if(!jobThreadActive)

		jobs.Add(JobInfo(cb, period));

	return *this;

}

void SkylarkApp::JobThread()

{

	SKYLARKLOG("Job thread started");

	for(;;) {

		if(quit)

			break;

		Time now = GetSysTime();

		for(int i = 0; i < jobs.GetCount(); i++){

			if (jobs[i].next <= now){

				SKYLARKLOG("Executing job #"<<i);

				jobs[i].cb.Execute();

				jobs[i].next = now + jobs[i].period;

				break;

			}

		}

		now = GetSysTime();

		Time next = now + 60;

		for(int i = 0; i < jobs.GetCount(); i++)

			next = min(jobs[i].next, next);

		if (next>now)

			Sleep((next-now)*1000);

	}

	SKYLARKLOG("Job thread finished");

}

}

	struct JobInfo : Moveable<JobInfo> {

		int period;

		Callback cb;

		Time next;

		JobInfo(Callback cb, int period) : period(period), cb(cb), next(0) {}

	};

	Vector<JobInfo> jobs;

	bool jobThreadActive;

	void JobThread();

	SkylarkApp& AddJob(Callback cb, int period);

	Jobs.cpp,