Function parallelReadAll

src/IECoreScene/SceneAlgo.cpp:243–277

{

SceneStats parallelReadAll( const SceneInterface *src, int startFrame, int endFrame, float frameRate, unsigned int flags )
{
	std::atomic<size_t> locationCount( 0 );
	::CopyInfo<std::atomic<size_t> > copyInfos;

	auto locationFn = [&locationCount, &copyInfos]( const SceneInterface *src, SceneInterface *dst, double time, unsigned int flags )
	{
		locationCount++;
		::CopyInfo<size_t> copyInfo = ::handleLocation( src, nullptr, time, flags );

		copyInfos.polygonCount += copyInfo.polygonCount;
		copyInfos.tagCount += copyInfo.tagCount;
		copyInfos.attributeCount += copyInfo.attributeCount;
		copyInfos.curveCount += copyInfo.curveCount;
		copyInfos.pointCount += copyInfo.pointCount;
	};

	for( int f = startFrame; f <= endFrame; ++f )
	{
		double time = f / frameRate;
		tbb::task_group_context taskGroupContext( tbb::task_group_context::isolated );
		Task<decltype( locationFn )> *task = new( tbb::task::allocate_root( taskGroupContext ) ) Task<decltype( locationFn )>( src, nullptr, locationFn, time, flags );
		tbb::task::spawn_root_and_wait( *task );
	}

	SceneStats stats;
	stats["locations"] = locationCount;
	stats["polygons"] = copyInfos.polygonCount;
	stats["curves"] = copyInfos.curveCount;
	stats["points"] = copyInfos.pointCount;
	stats["tags"] = copyInfos.tagCount;
	stats["sets"] = copyInfos.setCount;
	stats["attributes"] = copyInfos.attributeCount;
	return stats;
}

void copy( const SceneInterface *src, SceneInterface *dst, int startFrame, int endFrame, float frameRate, unsigned int flags )
{