Function main

examples/MultiThreading/main.cpp:110–166

int main(int argc, char** argv)
{
	int numThreads = 8;

	b3ThreadSupportInterface* threadSupport = createThreadSupport(numThreads);

	for (int i = 0; i < threadSupport->getNumTasks(); i++)
	{
		SampleThreadLocalStorage* storage = (SampleThreadLocalStorage*)threadSupport->getThreadLocalMemory(i);
		b3Assert(storage);
		storage->threadId = i;
	}

	SampleArgs args;
	args.m_cs = threadSupport->createCriticalSection();
	args.m_cs->setSharedParam(0, 100);

	int arg0, arg1;
	int i;
	for (i = 0; i < numThreads; i++)
	{
		threadSupport->runTask(B3_THREAD_SCHEDULE_TASK, (void*)&args, i);
	}

	bool blockingWait = false;
	if (blockingWait)
	{
		for (i = 0; i < numThreads; i++)
		{
			threadSupport->waitForResponse(&arg0, &arg1);
			printf("finished waiting for response: %d %d\n", arg0, arg1);
		}
	}
	else
	{
		int numActiveThreads = numThreads;
		while (numActiveThreads)
		{
			if (threadSupport->isTaskCompleted(&arg0, &arg1, 0))
			{
				numActiveThreads--;
				printf("numActiveThreads = %d\n", numActiveThreads);
			}
			else
			{
				//				printf("polling..");
			}
		};
	}

	printf("stopping threads\n");

	delete threadSupport;
	printf("Press ENTER to quit\n");
	//getchar();
	return 0;
}