Function testLRUCacheThreading

src/IECorePython/LRUCacheBinding.cpp:202–238

};

void testLRUCacheThreading( int numIterations, int numValues, int maxCost, int clearFrequency = 0 )
{
	// do lots of parallel cache accesses. then clear the cache in the main
	// thread and check that it has emptied successfully, to ensure that the
	// cost counting has been accurate.

	TestCache cache( get, maxCost );
	tbb::task_group_context taskGroupContext( tbb::task_group_context::isolated );
	parallel_for( blocked_range<size_t>( 0, numIterations ), GetFromTestCache( cache, numValues, clearFrequency ), taskGroupContext);

	if( cache.currentCost() > cache.getMaxCost() )
	{
		throw Exception( "LRUCache exceeds maximum cost" );
	}

	cache.clear();
	if( cache.currentCost() != 0 )
	{
		throw Exception( "Cost not 0 after LRUCache::clear()" );
	}

	// as above, but using setMaxCost( 0 ) to clear the cache.

	TestCache cache2( get, maxCost );
	parallel_for( blocked_range<size_t>( 0, numIterations ), GetFromTestCache( cache2, numValues, clearFrequency ), taskGroupContext );

	if( cache2.currentCost() > cache2.getMaxCost() )
	{
		throw Exception( "LRUCache exceeds maximum cost" );
	}

	cache2.setMaxCost( 0 );
	if( cache2.currentCost() != 0 )
	{
		throw Exception( "Cost not 0 after LRUCache::setMaxCost( 0 )" );
	}
}

typedef LRUCache<int, int, LRUCachePolicy::Serial> SerialTestCache;
typedef LRUCache<int, int, LRUCachePolicy::Parallel> ParallelTestCache;