thread_pool_test.cc File Reference

Tests for Thread Pool. More...

#include <gtest/gtest.h>
#include <thread_pool.H>
#include <atomic>
#include <chrono>
#include <vector>
#include <cmath>
#include <numeric>
#include <iomanip>
#include <algorithm>

Include dependency graph for thread_pool_test.cc:

Go to the source code of this file.

Classes
class	ThreadPoolTest
struct	Functor
struct	Calculator

Functions
	TEST_F (ThreadPoolTest, DefaultConstruction)
	TEST_F (ThreadPoolTest, ConstructionWithSize)
	TEST_F (ThreadPoolTest, ConstructionWithZeroDefaultsToOne)
	TEST_F (ThreadPoolTest, SimpleTask)
	TEST_F (ThreadPoolTest, TaskWithArguments)
	TEST_F (ThreadPoolTest, TaskWithReferenceCapture)
	TEST_F (ThreadPoolTest, VoidTask)
	TEST_F (ThreadPoolTest, MultipleTasks)
	TEST_F (ThreadPoolTest, CancellationSourceAndToken)
	TEST_F (ThreadPoolTest, TaskGroupWaitsForAllTasks)
	TEST_F (ThreadPoolTest, TaskGroupPropagatesExceptions)
	TEST_F (ThreadPoolTest, ParallelForIndexHonorsCancellation)
	TEST_F (ThreadPoolTest, ParallelInvokeRunsAllTasks)
	TEST_F (ThreadPoolTest, ParallelInvokePropagatesExceptions)
	TEST_F (ThreadPoolTest, ParallelInvokeHonorsCancellation)
	TEST_F (ThreadPoolTest, PscanMatchesPartialSum)
	TEST_F (ThreadPoolTest, PscanAcceptsParallelOptions)
	TEST_F (ThreadPoolTest, PexclusiveScanMatchesSequential)
	TEST_F (ThreadPoolTest, PscanHonorsCancellation)
	TEST_F (ThreadPoolTest, PmergeMatchesStdMerge)
	TEST_F (ThreadPoolTest, PmergeAcceptsParallelOptionsAndComparator)
	TEST_F (ThreadPoolTest, PmergeHonorsCancellation)
	TEST_F (ThreadPoolTest, PscanEmptyInput)
	TEST_F (ThreadPoolTest, PscanSingleElement)
	TEST_F (ThreadPoolTest, PexclusiveScanEmptyInput)
	TEST_F (ThreadPoolTest, PexclusiveScanSingleElement)
	TEST_F (ThreadPoolTest, PmergeEmptyLeft)
	TEST_F (ThreadPoolTest, PmergeEmptyRight)
	TEST_F (ThreadPoolTest, PmergeBothEmpty)
	TEST_F (ThreadPoolTest, BenchmarkScanAndMerge)
	TEST_F (ThreadPoolTest, PendingTasks)
	TEST_F (ThreadPoolTest, IsIdleAfterCompletion)
	TEST_F (ThreadPoolTest, ShutdownCompletesAllTasks)
	TEST_F (ThreadPoolTest, EnqueueAfterShutdownThrows)
	TEST_F (ThreadPoolTest, DoubleShutdownIsSafe)
	TEST_F (ThreadPoolTest, ResizeIncrease)
	TEST_F (ThreadPoolTest, ResizeDecrease)
	TEST_F (ThreadPoolTest, ResizeToSameIsNoOp)
	TEST_F (ThreadPoolTest, ResizeAfterShutdownThrows)
	TEST_F (ThreadPoolTest, ResizePreservesPendingTasks)
	TEST_F (ThreadPoolTest, ExceptionPropagation)
	TEST_F (ThreadPoolTest, ExceptionDoesNotAffectOtherTasks)
	TEST_F (ThreadPoolTest, ConcurrentEnqueue)
	TEST_F (ThreadPoolTest, ParallelExecution)
	TEST_F (ThreadPoolTest, ManySmallTasks)
	TEST_F (ThreadPoolTest, ComputeIntensiveTasks)
	TEST_F (ThreadPoolTest, ReturnString)
	TEST_F (ThreadPoolTest, ReturnVector)
	TEST_F (ThreadPoolTest, ReturnPair)
int	free_function (int x)
	TEST_F (ThreadPoolTest, FreeFunction)
	TEST_F (ThreadPoolTest, FunctorObject)
	TEST_F (ThreadPoolTest, StdFunction)
	TEST_F (ThreadPoolTest, MemberFunctionPointer)
	TEST_F (ThreadPoolTest, ConstMemberFunction)
	TEST_F (ThreadPoolTest, StaticMemberFunction)
	TEST_F (ThreadPoolTest, MemberFunctionWithReference)
	TEST_F (ThreadPoolTest, MoveOnlyLambda)
	TEST_F (ThreadPoolTest, MoveOnlyArgument)
	TEST_F (ThreadPoolTest, MoveOnlyFunctor)
	TEST_F (ThreadPoolTest, EnqueueDetachedBasic)
	TEST_F (ThreadPoolTest, EnqueueDetachedWithArgs)
	TEST_F (ThreadPoolTest, EnqueueDetachedExceptionsSilent)
	TEST_F (ThreadPoolTest, EnqueueDetachedAfterShutdownThrows)
	TEST_F (ThreadPoolTest, EnqueueBulkVector)
	TEST_F (ThreadPoolTest, EnqueueBulkStrings)
	TEST_F (ThreadPoolTest, EnqueueBulkEmpty)
	TEST_F (ThreadPoolTest, DefaultPoolExists)
	TEST_F (ThreadPoolTest, DefaultPoolWorks)
	TEST_F (ThreadPoolTest, DefaultPoolIsSingleton)
void	increment_ref (int &x)
void	add_to_ref (int &x, int amount)
	TEST_F (ThreadPoolTest, ReferenceArgumentWithStdRef)
	TEST_F (ThreadPoolTest, ReferenceArgumentMultipleParams)
	TEST_F (ThreadPoolTest, ConstReferenceWithStdCref)
	TEST_F (ThreadPoolTest, LambdaCaptureByReference)
	TEST_F (ThreadPoolTest, MemberFunctionWithStdRef)
	TEST_F (ThreadPoolTest, WaitAllBlocks)
	TEST_F (ThreadPoolTest, WaitAllOnEmptyPool)
	TEST_F (ThreadPoolTest, StressHighVolume)
	TEST_F (ThreadPoolTest, StressConcurrentEnqueueFromManyThreads)
	TEST_F (ThreadPoolTest, StressMixedWorkloads)
	TEST_F (ThreadPoolTest, SingleThreadPool)
	TEST_F (ThreadPoolTest, EmptyTasksSequence)
	TEST_F (ThreadPoolTest, VeryLargeReturnType)
	TEST_F (ThreadPoolTest, TaskReturningTask)
	TEST_F (ThreadPoolTest, RecursiveEnqueue)
	TEST_F (ThreadPoolTest, TaskThrowingDifferentExceptions)
	TEST_F (ThreadPoolTest, AllTasksThrowExceptions)
	TEST_F (ThreadPoolTest, ShutdownWhileTasksRunning)
	TEST_F (ThreadPoolTest, DestructorWaitsForTasks)
	TEST_F (ThreadPoolTest, ResizeUnderLoad)
	TEST_F (ThreadPoolTest, DataIntegrityUnderConcurrency)
	TEST_F (ThreadPoolTest, AtomicOperationsCorrectness)
	TEST_F (ThreadPoolTest, MutexProtectedSharedState)
	TEST_F (ThreadPoolTest, ParallelSpeedup)
	TEST_F (ThreadPoolTest, LowLatencySmallTasks)
	TEST_F (ThreadPoolTest, NestedLambdas)
	TEST_F (ThreadPoolTest, StdBindExpression)
	TEST_F (ThreadPoolTest, GenericLambda)
	TEST_F (ThreadPoolTest, CaptureByMoveInLambda)
	TEST_F (ThreadPoolTest, ManyArguments)
	TEST_F (ThreadPoolTest, ProducerConsumerPattern)
	TEST_F (ThreadPoolTest, SetQueueLimitsBasic)
	TEST_F (ThreadPoolTest, SetQueueLimitsDefaultHard)
	TEST_F (ThreadPoolTest, EnqueueBoundedBelowSoftLimit)
	TEST_F (ThreadPoolTest, EnqueueBoundedBlocksAtSoftLimit)
	TEST_F (ThreadPoolTest, EnqueueBoundedThrowsAtHardLimit)
	TEST_F (ThreadPoolTest, QueueOverflowErrorContainsInfo)
	TEST_F (ThreadPoolTest, EnqueueBoundedDetachedBlocksAtSoftLimit)
	TEST_F (ThreadPoolTest, BoundedEnqueueOnStoppedPoolThrows)
	TEST_F (ThreadPoolTest, BackpressureSlowsProducer)
	TEST_F (ThreadPoolTest, ConcurrentBoundedEnqueue)
	TEST_F (ThreadPoolTest, BoundedEnqueueWithFutureResults)
	TEST_F (ThreadPoolTest, BoundedEnqueueExceptionPropagation)
	TEST_F (ThreadPoolTest, MixedBoundedAndUnboundedEnqueue)
	TEST_F (ThreadPoolTest, BoundedEnqueueStressTest)
	TEST_F (ThreadPoolTest, UnlimitedByDefault)
	TEST_F (ThreadPoolTest, BoundedEnqueueWithArguments)
	TEST_F (ThreadPoolTest, BoundedEnqueueWithReference)
	TEST_F (ThreadPoolTest, TryEnqueueSucceedsWhenSpaceAvailable)
	TEST_F (ThreadPoolTest, TryEnqueueFailsWhenQueueFull)
	TEST_F (ThreadPoolTest, TryEnqueueDetachedSucceeds)
	TEST_F (ThreadPoolTest, TryEnqueueDetachedFailsWhenFull)
	TEST_F (ThreadPoolTest, TryEnqueueOnStoppedPoolThrows)
	TEST_F (ThreadPoolTest, TryEnqueueWithArguments)
	TEST_F (ThreadPoolTest, TryEnqueueNonBlockingBehavior)
	TEST_F (ThreadPoolTest, BenchmarkVsSequential)
	TEST_F (ThreadPoolTest, BenchmarkEnqueueOverhead)
	TEST_F (ThreadPoolTest, BenchmarkVsStdAsync)
	TEST_F (ThreadPoolTest, GetStatsInitialValues)
	TEST_F (ThreadPoolTest, StatsTrackCompletedTasks)
	TEST_F (ThreadPoolTest, StatsTrackPeakQueueSize)
	TEST_F (ThreadPoolTest, ResetStatsWorks)
	TEST_F (ThreadPoolTest, ExceptionCallbackInvokedOnDetachedTaskFailure)
	TEST_F (ThreadPoolTest, ExceptionCallbackCanBeCleared)
	TEST_F (ThreadPoolTest, StatsTrackFailedDetachedTasks)
	TEST_F (ThreadPoolTest, WaitAllForSucceedsWhenIdle)
	TEST_F (ThreadPoolTest, WaitAllForTimesOutWhenBusy)
	TEST_F (ThreadPoolTest, WaitAllUntilWorks)
	TEST_F (ThreadPoolTest, EnqueueBatchExecutesAllTasks)
	TEST_F (ThreadPoolTest, EnqueueBatchWithLargeWorkload)
	TEST_F (ThreadPoolTest, EnqueueBatchEmptyContainer)
	TEST_F (ThreadPoolTest, ParallelForModifiesElements)
	TEST_F (ThreadPoolTest, ParallelForWithChunkFunction)
	TEST_F (ThreadPoolTest, ParallelForEmptyRange)
	TEST_F (ThreadPoolTest, ParallelForCustomChunkSize)
	TEST_F (ThreadPoolTest, ParallelForIndexWorks)
	TEST_F (ThreadPoolTest, ParallelForIndexEmptyRange)
	TEST_F (ThreadPoolTest, ParallelTransformBasic)
	TEST_F (ThreadPoolTest, ParallelTransformLargeData)
	TEST_F (ThreadPoolTest, ParallelTransformEmpty)
	TEST_F (ThreadPoolTest, ParallelReduceSum)
	TEST_F (ThreadPoolTest, ParallelReduceProduct)
	TEST_F (ThreadPoolTest, ParallelReduceMax)
	TEST_F (ThreadPoolTest, ParallelReduceLargeData)
	TEST_F (ThreadPoolTest, ParallelReduceEmpty)
	TEST_F (ThreadPoolTest, ThreadPoolStatsQueueUtilization)
int	main (int argc, char **argv)

Detailed Description

Tests for Thread Pool.

Note: Updated to reflect header Doxygen group changes.

Definition in file thread_pool_test.cc.

Function Documentation

add_to_ref()

void add_to_ref	(	int &	x,
		int	amount
	)

Definition at line 1089 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp().

Referenced by TEST_F().

free_function()

int free_function

(

int

x

)

Definition at line 823 of file thread_pool_test.cc.

Referenced by TEST_F().

increment_ref()

void increment_ref

(

int &

x

)

Definition at line 1088 of file thread_pool_test.cc.

Referenced by TEST_F().

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 2814 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp().

TEST_F() [1/155]

TEST_F	(	ThreadPoolTest	,
		AllTasksThrowExceptions
	)

Definition at line 1341 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [2/155]

TEST_F	(	ThreadPoolTest	,
		AtomicOperationsCorrectness
	)

Definition at line 1488 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::sum(), and Aleph::ThreadPool::wait_all().

TEST_F() [3/155]

TEST_F	(	ThreadPoolTest	,
		BackpressureSlowsProducer
	)

Definition at line 1901 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded_detached(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::wait_all().

TEST_F() [4/155]

TEST_F	(	ThreadPoolTest	,
		BenchmarkEnqueueOverhead
	)

Definition at line 2285 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [5/155]

TEST_F	(	ThreadPoolTest	,
		BenchmarkScanAndMerge
	)

Definition at line 453 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), LL, Aleph::pmerge(), and Aleph::pscan().

TEST_F() [6/155]

TEST_F	(	ThreadPoolTest	,
		BenchmarkVsSequential
	)

Definition at line 2232 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [7/155]

TEST_F	(	ThreadPoolTest	,
		BenchmarkVsStdAsync
	)

Definition at line 2313 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), and Aleph::sum().

TEST_F() [8/155]

TEST_F	(	ThreadPoolTest	,
		BoundedEnqueueExceptionPropagation
	)

Definition at line 1994 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded(), and Aleph::ThreadPool::set_queue_limits().

TEST_F() [9/155]

TEST_F	(	ThreadPoolTest	,
		BoundedEnqueueOnStoppedPoolThrows
	)

Definition at line 1891 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded(), Aleph::ThreadPool::enqueue_bounded_detached(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::shutdown().

TEST_F() [10/155]

TEST_F	(	ThreadPoolTest	,
		BoundedEnqueueStressTest
	)

Definition at line 2036 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded_detached(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::wait_all().

TEST_F() [11/155]

TEST_F	(	ThreadPoolTest	,
		BoundedEnqueueWithArguments
	)

Definition at line 2079 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded(), and Aleph::ThreadPool::set_queue_limits().

TEST_F() [12/155]

TEST_F	(	ThreadPoolTest	,
		BoundedEnqueueWithFutureResults
	)

Definition at line 1981 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded(), and Aleph::ThreadPool::set_queue_limits().

TEST_F() [13/155]

TEST_F	(	ThreadPoolTest	,
		BoundedEnqueueWithReference
	)

Definition at line 2091 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded(), and Aleph::ThreadPool::set_queue_limits().

TEST_F() [14/155]

TEST_F	(	ThreadPoolTest	,
		CancellationSourceAndToken
	)

Definition at line 136 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::CancellationSource::request_cancel(), and Aleph::CancellationSource::token().

TEST_F() [15/155]

TEST_F	(	ThreadPoolTest	,
		CaptureByMoveInLambda
	)

Definition at line 1636 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [16/155]

TEST_F	(	ThreadPoolTest	,
		ComputeIntensiveTasks
	)

Definition at line 749 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), Aleph::ThreadPool::is_idle(), and Aleph::sum().

TEST_F() [17/155]

TEST_F	(	ThreadPoolTest	,
		ConcurrentBoundedEnqueue
	)

Definition at line 1944 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded_detached(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::wait_all().

TEST_F() [18/155]

TEST_F	(	ThreadPoolTest	,
		ConcurrentEnqueue
	)

Definition at line 663 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [19/155]

TEST_F	(	ThreadPoolTest	,
		ConstMemberFunction
	)

Definition at line 884 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [20/155]

TEST_F	(	ThreadPoolTest	,
		ConstReferenceWithStdCref
	)

Definition at line 1113 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [21/155]

TEST_F	(	ThreadPoolTest	,
		ConstructionWithSize
	)

Definition at line 72 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::num_threads().

TEST_F() [22/155]

TEST_F	(	ThreadPoolTest	,
		ConstructionWithZeroDefaultsToOne
	)

Definition at line 78 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::num_threads().

TEST_F() [23/155]

TEST_F	(	ThreadPoolTest	,
		DataIntegrityUnderConcurrency
	)

Definition at line 1472 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [24/155]

TEST_F	(	ThreadPoolTest	,
		DefaultConstruction
	)

Definition at line 64 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::is_idle(), Aleph::ThreadPool::is_stopped(), and Aleph::ThreadPool::num_threads().

TEST_F() [25/155]

TEST_F	(	ThreadPoolTest	,
		DefaultPoolExists
	)

Definition at line 1061 of file thread_pool_test.cc.

References Aleph::default_pool(), and Aleph::divide_and_conquer_partition_dp().

TEST_F() [26/155]

TEST_F	(	ThreadPoolTest	,
		DefaultPoolIsSingleton
	)

Definition at line 1076 of file thread_pool_test.cc.

References Aleph::default_pool(), and Aleph::divide_and_conquer_partition_dp().

TEST_F() [27/155]

TEST_F	(	ThreadPoolTest	,
		DefaultPoolWorks
	)

Definition at line 1069 of file thread_pool_test.cc.

References Aleph::default_pool(), Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [28/155]

TEST_F	(	ThreadPoolTest	,
		DestructorWaitsForTasks
	)

Definition at line 1404 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue_detached().

TEST_F() [29/155]

TEST_F	(	ThreadPoolTest	,
		DoubleShutdownIsSafe
	)

Definition at line 553 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::shutdown().

TEST_F() [30/155]

TEST_F	(	ThreadPoolTest	,
		EmptyTasksSequence
	)

Definition at line 1266 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::is_idle(), and Aleph::ThreadPool::wait_all().

TEST_F() [31/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueAfterShutdownThrows
	)

Definition at line 545 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), and Aleph::ThreadPool::shutdown().

TEST_F() [32/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueBatchEmptyContainer
	)

Definition at line 2600 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue_batch().

TEST_F() [33/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueBatchExecutesAllTasks
	)

Definition at line 2563 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue_batch().

TEST_F() [34/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueBatchWithLargeWorkload
	)

Definition at line 2582 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_batch(), and Aleph::sum().

TEST_F() [35/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueBoundedBelowSoftLimit
	)

Definition at line 1746 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded(), and Aleph::ThreadPool::set_queue_limits().

TEST_F() [36/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueBoundedBlocksAtSoftLimit
	)

Definition at line 1760 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded_detached(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::pending_tasks(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::wait_all().

TEST_F() [37/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueBoundedDetachedBlocksAtSoftLimit
	)

Definition at line 1859 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded_detached(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::wait_all().

TEST_F() [38/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueBoundedThrowsAtHardLimit
	)

Definition at line 1803 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::wait_all().

TEST_F() [39/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueBulkEmpty
	)

Definition at line 1047 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue_bulk().

TEST_F() [40/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueBulkStrings
	)

Definition at line 1032 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue_bulk().

TEST_F() [41/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueBulkVector
	)

Definition at line 1017 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue_bulk().

TEST_F() [42/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueDetachedAfterShutdownThrows
	)

Definition at line 1005 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::shutdown().

TEST_F() [43/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueDetachedBasic
	)

Definition at line 965 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [44/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueDetachedExceptionsSilent
	)

Definition at line 991 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [45/155]

TEST_F	(	ThreadPoolTest	,
		EnqueueDetachedWithArgs
	)

Definition at line 978 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::sum(), and Aleph::ThreadPool::wait_all().

TEST_F() [46/155]

TEST_F	(	ThreadPoolTest	,
		ExceptionCallbackCanBeCleared
	)

Definition at line 2476 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::set_exception_callback(), and Aleph::ThreadPool::wait_all().

TEST_F() [47/155]

TEST_F	(	ThreadPoolTest	,
		ExceptionCallbackInvokedOnDetachedTaskFailure
	)

Definition at line 2447 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::set_exception_callback(), and Aleph::ThreadPool::wait_all().

TEST_F() [48/155]

TEST_F	(	ThreadPoolTest	,
		ExceptionDoesNotAffectOtherTasks
	)

Definition at line 644 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [49/155]

TEST_F	(	ThreadPoolTest	,
		ExceptionPropagation
	)

Definition at line 632 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [50/155]

TEST_F	(	ThreadPoolTest	,
		FreeFunction
	)

Definition at line 831 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), and free_function().

TEST_F() [51/155]

TEST_F	(	ThreadPoolTest	,
		FunctorObject
	)

Definition at line 840 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [52/155]

TEST_F	(	ThreadPoolTest	,
		GenericLambda
	)

Definition at line 1622 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [53/155]

TEST_F	(	ThreadPoolTest	,
		GetStatsInitialValues
	)

Definition at line 2373 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::get_stats().

TEST_F() [54/155]

TEST_F	(	ThreadPoolTest	,
		IsIdleAfterCompletion
	)

Definition at line 513 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), Aleph::ThreadPool::is_idle(), and Aleph::ThreadPool::wait_all().

TEST_F() [55/155]

TEST_F	(	ThreadPoolTest	,
		LambdaCaptureByReference
	)

Definition at line 1123 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [56/155]

TEST_F	(	ThreadPoolTest	,
		LowLatencySmallTasks
	)

Definition at line 1566 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [57/155]

TEST_F	(	ThreadPoolTest	,
		ManyArguments
	)

Definition at line 1653 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), and h.

TEST_F() [58/155]

TEST_F	(	ThreadPoolTest	,
		ManySmallTasks
	)

Definition at line 721 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), and Aleph::sum().

TEST_F() [59/155]

TEST_F	(	ThreadPoolTest	,
		MemberFunctionPointer
	)

Definition at line 873 of file thread_pool_test.cc.

References Calculator::add(), Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [60/155]

TEST_F	(	ThreadPoolTest	,
		MemberFunctionWithReference
	)

Definition at line 903 of file thread_pool_test.cc.

References Calculator::add(), Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [61/155]

TEST_F	(	ThreadPoolTest	,
		MemberFunctionWithStdRef
	)

Definition at line 1134 of file thread_pool_test.cc.

References Calculator::add(), Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [62/155]

TEST_F	(	ThreadPoolTest	,
		MixedBoundedAndUnboundedEnqueue
	)

Definition at line 2006 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded_detached(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::wait_all().

TEST_F() [63/155]

TEST_F	(	ThreadPoolTest	,
		MoveOnlyArgument
	)

Definition at line 929 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [64/155]

TEST_F	(	ThreadPoolTest	,
		MoveOnlyFunctor
	)

Definition at line 940 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [65/155]

TEST_F	(	ThreadPoolTest	,
		MoveOnlyLambda
	)

Definition at line 919 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [66/155]

TEST_F	(	ThreadPoolTest	,
		MultipleTasks
	)

Definition at line 123 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [67/155]

TEST_F	(	ThreadPoolTest	,
		MutexProtectedSharedState
	)

Definition at line 1504 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [68/155]

TEST_F	(	ThreadPoolTest	,
		NestedLambdas
	)

Definition at line 1592 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), and y.

TEST_F() [69/155]

TEST_F	(	ThreadPoolTest	,
		ParallelExecution
	)

Definition at line 687 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [70/155]

TEST_F	(	ThreadPoolTest	,
		ParallelForCustomChunkSize
	)

Definition at line 2652 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::parallel_for().

TEST_F() [71/155]

TEST_F	(	ThreadPoolTest	,
		ParallelForEmptyRange
	)

Definition at line 2640 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::parallel_for().

TEST_F() [72/155]

TEST_F	(	ThreadPoolTest	,
		ParallelForIndexEmptyRange
	)

Definition at line 2684 of file thread_pool_test.cc.

References Aleph::parallel_for_index().

TEST_F() [73/155]

TEST_F	(	ThreadPoolTest	,
		ParallelForIndexHonorsCancellation
	)

Definition at line 183 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, Aleph::parallel_for_index(), Aleph::ParallelOptions::pool, Aleph::CancellationSource::request_cancel(), and Aleph::CancellationSource::token().

TEST_F() [74/155]

TEST_F	(	ThreadPoolTest	,
		ParallelForIndexWorks
	)

Definition at line 2670 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::parallel_for_index().

TEST_F() [75/155]

TEST_F	(	ThreadPoolTest	,
		ParallelForModifiesElements
	)

Definition at line 2612 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::parallel_for().

TEST_F() [76/155]

TEST_F	(	ThreadPoolTest	,
		ParallelForWithChunkFunction
	)

Definition at line 2624 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::parallel_for().

TEST_F() [77/155]

TEST_F	(	ThreadPoolTest	,
		ParallelInvokeHonorsCancellation
	)

Definition at line 231 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, Aleph::parallel_invoke(), Aleph::ParallelOptions::pool, Aleph::CancellationSource::request_cancel(), and Aleph::CancellationSource::token().

TEST_F() [78/155]

TEST_F	(	ThreadPoolTest	,
		ParallelInvokePropagatesExceptions
	)

Definition at line 218 of file thread_pool_test.cc.

References Aleph::completed(), Aleph::divide_and_conquer_partition_dp(), and Aleph::parallel_invoke().

TEST_F() [79/155]

TEST_F	(	ThreadPoolTest	,
		ParallelInvokeRunsAllTasks
	)

Definition at line 205 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::parallel_invoke(), and Aleph::sum().

TEST_F() [80/155]

TEST_F	(	ThreadPoolTest	,
		ParallelReduceEmpty
	)

Definition at line 2789 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::parallel_reduce().

TEST_F() [81/155]

TEST_F	(	ThreadPoolTest	,
		ParallelReduceLargeData
	)

Definition at line 2775 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), LL, Aleph::parallel_reduce(), and Aleph::sum().

TEST_F() [82/155]

TEST_F	(	ThreadPoolTest	,
		ParallelReduceMax
	)

Definition at line 2762 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::parallel_reduce().

TEST_F() [83/155]

TEST_F	(	ThreadPoolTest	,
		ParallelReduceProduct
	)

Definition at line 2750 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::parallel_reduce(), and Aleph::product().

TEST_F() [84/155]

TEST_F	(	ThreadPoolTest	,
		ParallelReduceSum
	)

Definition at line 2739 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::parallel_reduce(), and Aleph::sum().

TEST_F() [85/155]

TEST_F	(	ThreadPoolTest	,
		ParallelSpeedup
	)

Definition at line 1533 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp().

TEST_F() [86/155]

TEST_F	(	ThreadPoolTest	,
		ParallelTransformBasic
	)

Definition at line 2695 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), output, and Aleph::parallel_transform().

TEST_F() [87/155]

TEST_F	(	ThreadPoolTest	,
		ParallelTransformEmpty
	)

Definition at line 2724 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), output, and Aleph::parallel_transform().

TEST_F() [88/155]

TEST_F	(	ThreadPoolTest	,
		ParallelTransformLargeData
	)

Definition at line 2708 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), output, and Aleph::parallel_transform().

TEST_F() [89/155]

TEST_F	(	ThreadPoolTest	,
		PendingTasks
	)

Definition at line 491 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::pending_tasks(), and Aleph::ThreadPool::wait_all().

TEST_F() [90/155]

TEST_F	(	ThreadPoolTest	,
		PexclusiveScanEmptyInput
	)

Definition at line 379 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, output, Aleph::pexclusive_scan(), and Aleph::ParallelOptions::pool.

TEST_F() [91/155]

TEST_F	(	ThreadPoolTest	,
		PexclusiveScanMatchesSequential
	)

Definition at line 273 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), output, and Aleph::pexclusive_scan().

TEST_F() [92/155]

TEST_F	(	ThreadPoolTest	,
		PexclusiveScanSingleElement
	)

Definition at line 392 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, output, Aleph::pexclusive_scan(), and Aleph::ParallelOptions::pool.

TEST_F() [93/155]

TEST_F	(	ThreadPoolTest	,
		PmergeAcceptsParallelOptionsAndComparator
	)

Definition at line 313 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, Aleph::pmerge(), and Aleph::ParallelOptions::pool.

TEST_F() [94/155]

TEST_F	(	ThreadPoolTest	,
		PmergeBothEmpty
	)

Definition at line 439 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, Aleph::pmerge(), and Aleph::ParallelOptions::pool.

TEST_F() [95/155]

TEST_F	(	ThreadPoolTest	,
		PmergeEmptyLeft
	)

Definition at line 407 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, Aleph::pmerge(), and Aleph::ParallelOptions::pool.

TEST_F() [96/155]

TEST_F	(	ThreadPoolTest	,
		PmergeEmptyRight
	)

Definition at line 423 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, Aleph::pmerge(), and Aleph::ParallelOptions::pool.

TEST_F() [97/155]

TEST_F	(	ThreadPoolTest	,
		PmergeHonorsCancellation
	)

Definition at line 329 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, Aleph::pmerge(), Aleph::ParallelOptions::pool, Aleph::CancellationSource::request_cancel(), and Aleph::CancellationSource::token().

TEST_F() [98/155]

TEST_F	(	ThreadPoolTest	,
		PmergeMatchesStdMerge
	)

Definition at line 300 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::pmerge().

TEST_F() [99/155]

TEST_F	(	ThreadPoolTest	,
		ProducerConsumerPattern
	)

Definition at line 1671 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [100/155]

TEST_F	(	ThreadPoolTest	,
		PscanAcceptsParallelOptions
	)

Definition at line 260 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, output, Aleph::ParallelOptions::pool, and Aleph::pscan().

TEST_F() [101/155]

TEST_F	(	ThreadPoolTest	,
		PscanEmptyInput
	)

Definition at line 351 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, output, Aleph::ParallelOptions::pool, and Aleph::pscan().

TEST_F() [102/155]

TEST_F	(	ThreadPoolTest	,
		PscanHonorsCancellation
	)

Definition at line 283 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, output, Aleph::ParallelOptions::pool, Aleph::pscan(), Aleph::CancellationSource::request_cancel(), and Aleph::CancellationSource::token().

TEST_F() [103/155]

TEST_F	(	ThreadPoolTest	,
		PscanMatchesPartialSum
	)

Definition at line 246 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), output, and Aleph::pscan().

TEST_F() [104/155]

TEST_F	(	ThreadPoolTest	,
		PscanSingleElement
	)

Definition at line 364 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), options, output, Aleph::ParallelOptions::pool, and Aleph::pscan().

TEST_F() [105/155]

TEST_F	(	ThreadPoolTest	,
		QueueOverflowErrorContainsInfo
	)

Definition at line 1828 of file thread_pool_test.cc.

References Aleph::queue_overflow_error::current_size(), Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_bounded(), Aleph::ThreadPool::enqueue_detached(), FAIL, Aleph::queue_overflow_error::hard_limit(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::wait_all().

TEST_F() [106/155]

TEST_F	(	ThreadPoolTest	,
		RecursiveEnqueue
	)

Definition at line 1306 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [107/155]

TEST_F	(	ThreadPoolTest	,
		ReferenceArgumentMultipleParams
	)

Definition at line 1102 of file thread_pool_test.cc.

References add_to_ref(), Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [108/155]

TEST_F	(	ThreadPoolTest	,
		ReferenceArgumentWithStdRef
	)

Definition at line 1091 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), and increment_ref().

TEST_F() [109/155]

TEST_F	(	ThreadPoolTest	,
		ResetStatsWorks
	)

Definition at line 2427 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), Aleph::ThreadPool::get_stats(), Aleph::ThreadPool::reset_stats(), and Aleph::ThreadPool::wait_all().

TEST_F() [110/155]

TEST_F	(	ThreadPoolTest	,
		ResizeAfterShutdownThrows
	)

Definition at line 597 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::resize(), and Aleph::ThreadPool::shutdown().

TEST_F() [111/155]

TEST_F	(	ThreadPoolTest	,
		ResizeDecrease
	)

Definition at line 577 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), Aleph::ThreadPool::num_threads(), and Aleph::ThreadPool::resize().

TEST_F() [112/155]

TEST_F	(	ThreadPoolTest	,
		ResizeIncrease
	)

Definition at line 564 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), Aleph::ThreadPool::num_threads(), and Aleph::ThreadPool::resize().

TEST_F() [113/155]

TEST_F	(	ThreadPoolTest	,
		ResizePreservesPendingTasks
	)

Definition at line 605 of file thread_pool_test.cc.

References Aleph::completed(), Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::resize(), and Aleph::ThreadPool::wait_all().

TEST_F() [114/155]

TEST_F	(	ThreadPoolTest	,
		ResizeToSameIsNoOp
	)

Definition at line 590 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::num_threads(), and Aleph::ThreadPool::resize().

TEST_F() [115/155]

TEST_F	(	ThreadPoolTest	,
		ResizeUnderLoad
	)

Definition at line 1423 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::resize(), and Aleph::ThreadPool::wait_all().

TEST_F() [116/155]

TEST_F	(	ThreadPoolTest	,
		ReturnPair
	)

Definition at line 806 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), Aleph::product(), and Aleph::sum().

TEST_F() [117/155]

TEST_F	(	ThreadPoolTest	,
		ReturnString
	)

Definition at line 784 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [118/155]

TEST_F	(	ThreadPoolTest	,
		ReturnVector
	)

Definition at line 793 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [119/155]

TEST_F	(	ThreadPoolTest	,
		SetQueueLimitsBasic
	)

Definition at line 1724 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::get_queue_limits(), and Aleph::ThreadPool::set_queue_limits().

TEST_F() [120/155]

TEST_F	(	ThreadPoolTest	,
		SetQueueLimitsDefaultHard
	)

Definition at line 1735 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::get_queue_limits(), and Aleph::ThreadPool::set_queue_limits().

TEST_F() [121/155]

TEST_F	(	ThreadPoolTest	,
		ShutdownCompletesAllTasks
	)

Definition at line 531 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::is_stopped(), and Aleph::ThreadPool::shutdown().

TEST_F() [122/155]

TEST_F	(	ThreadPoolTest	,
		ShutdownWhileTasksRunning
	)

Definition at line 1373 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::shutdown().

TEST_F() [123/155]

TEST_F	(	ThreadPoolTest	,
		SimpleTask
	)

Definition at line 84 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [124/155]

TEST_F	(	ThreadPoolTest	,
		SingleThreadPool
	)

Definition at line 1246 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [125/155]

TEST_F	(	ThreadPoolTest	,
		StaticMemberFunction
	)

Definition at line 894 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [126/155]

TEST_F	(	ThreadPoolTest	,
		StatsTrackCompletedTasks
	)

Definition at line 2387 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), Aleph::ThreadPool::get_stats(), and Aleph::ThreadPool::wait_all().

TEST_F() [127/155]

TEST_F	(	ThreadPoolTest	,
		StatsTrackFailedDetachedTasks
	)

Definition at line 2503 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::get_stats(), and Aleph::ThreadPool::wait_all().

TEST_F() [128/155]

TEST_F	(	ThreadPoolTest	,
		StatsTrackPeakQueueSize
	)

Definition at line 2405 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::get_stats(), and Aleph::ThreadPool::wait_all().

TEST_F() [129/155]

TEST_F	(	ThreadPoolTest	,
		StdBindExpression
	)

Definition at line 1610 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [130/155]

TEST_F	(	ThreadPoolTest	,
		StdFunction
	)

Definition at line 850 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [131/155]

TEST_F	(	ThreadPoolTest	,
		StressConcurrentEnqueueFromManyThreads
	)

Definition at line 1196 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [132/155]

TEST_F	(	ThreadPoolTest	,
		StressHighVolume
	)

Definition at line 1182 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [133/155]

TEST_F	(	ThreadPoolTest	,
		StressMixedWorkloads
	)

Definition at line 1220 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [134/155]

TEST_F	(	ThreadPoolTest	,
		TaskGroupPropagatesExceptions
	)

Definition at line 162 of file thread_pool_test.cc.

References Aleph::completed(), and Aleph::divide_and_conquer_partition_dp().

TEST_F() [135/155]

TEST_F	(	ThreadPoolTest	,
		TaskGroupWaitsForAllTasks
	)

Definition at line 147 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::sum().

TEST_F() [136/155]

TEST_F	(	ThreadPoolTest	,
		TaskReturningTask
	)

Definition at line 1293 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [137/155]

TEST_F	(	ThreadPoolTest	,
		TaskThrowingDifferentExceptions
	)

Definition at line 1326 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [138/155]

TEST_F	(	ThreadPoolTest	,
		TaskWithArguments
	)

Definition at line 93 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [139/155]

TEST_F	(	ThreadPoolTest	,
		TaskWithReferenceCapture
	)

Definition at line 102 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [140/155]

TEST_F	(	ThreadPoolTest	,
		ThreadPoolStatsQueueUtilization
	)

Definition at line 2803 of file thread_pool_test.cc.

References Aleph::ThreadPoolStats::current_queue_size, Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPoolStats::queue_utilization().

TEST_F() [141/155]

TEST_F	(	ThreadPoolTest	,
		TryEnqueueDetachedFailsWhenFull
	)

Definition at line 2155 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::set_queue_limits(), Aleph::ThreadPool::try_enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [142/155]

TEST_F	(	ThreadPoolTest	,
		TryEnqueueDetachedSucceeds
	)

Definition at line 2142 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::set_queue_limits(), Aleph::ThreadPool::try_enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [143/155]

TEST_F	(	ThreadPoolTest	,
		TryEnqueueFailsWhenQueueFull
	)

Definition at line 2119 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::set_queue_limits(), Aleph::ThreadPool::try_enqueue(), and Aleph::ThreadPool::wait_all().

TEST_F() [144/155]

TEST_F	(	ThreadPoolTest	,
		TryEnqueueNonBlockingBehavior
	)

Definition at line 2198 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::set_queue_limits(), Aleph::ThreadPool::try_enqueue(), and Aleph::ThreadPool::wait_all().

TEST_F() [145/155]

TEST_F	(	ThreadPoolTest	,
		TryEnqueueOnStoppedPoolThrows
	)

Definition at line 2178 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::shutdown(), Aleph::ThreadPool::try_enqueue(), and Aleph::ThreadPool::try_enqueue_detached().

TEST_F() [146/155]

TEST_F	(	ThreadPoolTest	,
		TryEnqueueSucceedsWhenSpaceAvailable
	)

Definition at line 2108 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::try_enqueue().

TEST_F() [147/155]

TEST_F	(	ThreadPoolTest	,
		TryEnqueueWithArguments
	)

Definition at line 2187 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::set_queue_limits(), and Aleph::ThreadPool::try_enqueue().

TEST_F() [148/155]

TEST_F	(	ThreadPoolTest	,
		UnlimitedByDefault
	)

Definition at line 2069 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::get_queue_limits().

TEST_F() [149/155]

TEST_F	(	ThreadPoolTest	,
		VeryLargeReturnType
	)

Definition at line 1278 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [150/155]

TEST_F	(	ThreadPoolTest	,
		VoidTask
	)

Definition at line 112 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::enqueue().

TEST_F() [151/155]

TEST_F	(	ThreadPoolTest	,
		WaitAllBlocks
	)

Definition at line 1149 of file thread_pool_test.cc.

References counter, Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), and Aleph::ThreadPool::wait_all().

TEST_F() [152/155]

TEST_F	(	ThreadPoolTest	,
		WaitAllForSucceedsWhenIdle
	)

Definition at line 2522 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), and Aleph::ThreadPool::wait_all_for().

TEST_F() [153/155]

TEST_F	(	ThreadPoolTest	,
		WaitAllForTimesOutWhenBusy
	)

Definition at line 2532 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue_detached(), Aleph::ThreadPool::wait_all(), and Aleph::ThreadPool::wait_all_for().

TEST_F() [154/155]

TEST_F	(	ThreadPoolTest	,
		WaitAllOnEmptyPool
	)

Definition at line 1165 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::ThreadPool::wait_all().

TEST_F() [155/155]

TEST_F	(	ThreadPoolTest	,
		WaitAllUntilWorks
	)

Definition at line 2550 of file thread_pool_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::ThreadPool::enqueue(), and Aleph::ThreadPool::wait_all_until().