498da0721b
Added Demos/ThreadingDemo showing how to use the cross-platform btThreadSupportInterface under Windows. Added Demos/ParticlesOpenCL showing how to run the NVidia particle demo under OpenCL implementations by AMD, NVidia and MiniCL (CPU)
123 lines
3.4 KiB
C++
123 lines
3.4 KiB
C++
/*
|
|
Bullet Continuous Collision Detection and Physics Library
|
|
Copyright (c) 2010 Erwin Coumans http://bulletphysics.org
|
|
|
|
This software is provided 'as-is', without any express or implied warranty.
|
|
In no event will the authors be held liable for any damages arising from the use of this software.
|
|
Permission is granted to anyone to use this software for any purpose,
|
|
including commercial applications, and to alter it and redistribute it freely,
|
|
subject to the following restrictions:
|
|
|
|
1. The origin of this software must not be misrepresented; you must not claim that you wrote the original software. If you use this software in a product, an acknowledgment in the product documentation would be appreciated but is not required.
|
|
2. Altered source versions must be plainly marked as such, and must not be misrepresented as being the original software.
|
|
3. This notice may not be removed or altered from any source distribution.
|
|
*/
|
|
|
|
/// ThreadingDemo shows how to use the cross platform thread support interface.
|
|
/// You can start threads and perform a blocking wait for completion
|
|
/// Under Windows it uses Win32 Threads. On Mac and Linux it uses pthreads. On PlayStation 3 Cell SPU it uses SPURS.
|
|
|
|
/// June 2010
|
|
/// New: critical section/barriers and non-blocking pollingn for completion, currently Windows only
|
|
|
|
#include "BulletMultiThreaded/Win32ThreadSupport.h"
|
|
|
|
struct SampleArgs
|
|
{
|
|
btCriticalSection* m_cs;
|
|
};
|
|
|
|
struct SampleThreadLocalStorage
|
|
{
|
|
int threadId;
|
|
};
|
|
|
|
|
|
void SampleThreadFunc(void* userPtr,void* lsMemory)
|
|
{
|
|
SampleThreadLocalStorage* localStorage = (SampleThreadLocalStorage*) lsMemory;
|
|
|
|
SampleArgs* args = (SampleArgs*) userPtr;
|
|
int workLeft = true;
|
|
while (workLeft)
|
|
{
|
|
args->m_cs->lock();
|
|
int count = args->m_cs->getSharedParam(0);
|
|
args->m_cs->setSharedParam(0,count-1);
|
|
args->m_cs->unlock();
|
|
if (count>0)
|
|
{
|
|
printf("thread %d processed number %d\n",localStorage->threadId, count);
|
|
}
|
|
workLeft = count>0;
|
|
}
|
|
printf("finished\n");
|
|
//do nothing
|
|
}
|
|
|
|
|
|
void* SamplelsMemoryFunc()
|
|
{
|
|
//don't create local store memory, just return 0
|
|
return new SampleThreadLocalStorage;
|
|
}
|
|
|
|
|
|
|
|
int main(int argc,char** argv)
|
|
{
|
|
int numThreads = 4;
|
|
|
|
Win32ThreadSupport::Win32ThreadConstructionInfo threadConstructionInfo("testThreads",SampleThreadFunc,SamplelsMemoryFunc,numThreads);
|
|
|
|
Win32ThreadSupport* threadSupport = new Win32ThreadSupport(threadConstructionInfo);
|
|
|
|
threadSupport->startSPU();
|
|
|
|
for (int i=0;i<threadSupport->getNumTasks();i++)
|
|
{
|
|
SampleThreadLocalStorage* storage = (SampleThreadLocalStorage*)threadSupport->getThreadLocalMemory(i);
|
|
storage->threadId = i;
|
|
}
|
|
|
|
|
|
SampleArgs args;
|
|
args.m_cs = threadSupport->createCriticalSection();
|
|
args.m_cs->setSharedParam(0,100);
|
|
|
|
|
|
unsigned int arg0,arg1;
|
|
int i;
|
|
for (i=0;i<numThreads;i++)
|
|
{
|
|
threadSupport->sendRequest(1, (ppu_address_t) &args, i);
|
|
}
|
|
|
|
bool blockingWait = false;
|
|
if (blockingWait)
|
|
{
|
|
for (i=0;i<numThreads;i++)
|
|
{
|
|
threadSupport->waitForResponse(&arg0,&arg1);
|
|
}
|
|
} else
|
|
{
|
|
int numActiveThreads = numThreads;
|
|
while (numActiveThreads)
|
|
{
|
|
if (threadSupport->isTaskCompleted(&arg0,&arg1,0))
|
|
{
|
|
numActiveThreads--;
|
|
printf("numActiveThreads = %d\n",numActiveThreads);
|
|
|
|
} else
|
|
{
|
|
printf("polling\n");
|
|
}
|
|
};
|
|
}
|
|
|
|
threadSupport->stopSPU();
|
|
delete threadSupport;
|
|
return 0;
|
|
} |