Function fxRunLoop

xs/tools/xst.c:972–1012

}

void fxRunLoop(txMachine* the)
{
	txThread thread = mxCurrentThread();
	txNumber when;
	txInteger count;
	txSharedTimer* timer;
	
	for (;;) {
		fxEndJob(the);
		while (the->promiseJobs) {
			while (the->promiseJobs) {
				the->promiseJobs = 0;
				fxRunPromiseJobs(the);
			}
			fxEndJob(the);
		}
		when = mxMonotonicNow();
		fxLockMutex(&(gxSharedTimers.mutex));
		count = 0;
		timer = gxSharedTimers.first;
		while (timer) {
			if (timer->thread == thread) {
				count++;
				if (timer->when <= when)
					break; // one timer at time to run promise jobs queued by the timer in the same "tick"
			}
			timer = timer->next;
		}
		fxUnlockMutex(&(gxSharedTimers.mutex));
		if (timer) {
			(timer->callback)(timer, timer->refcon, timer->refconSize);
			if (timer->interval == 0)
				fxUnscheduleSharedTimer(timer);
			else
				timer->when += timer->interval;
			continue;
		}
		if (count == 0)
			break;
	}
}

void fxFulfillModuleFile(txMachine* the)
{