concurrency_utils_test.cc File Reference

#include <gtest/gtest.h>
#include <concurrency_utils.H>
#include <thread_pool.H>
#include <algorithm>
#include <atomic>
#include <chrono>
#include <future>
#include <memory>
#include <numeric>
#include <stdexcept>
#include <thread>
#include <vector>

Include dependency graph for concurrency_utils_test.cc:

Go to the source code of this file.

Concepts
concept	@552::SupportsValueReturningWithLock
concept	@552::SupportsValueReturningWithReadLock
concept	@552::SupportsValueReturningWithWriteLock

Functions
	TEST (ConcurrencyUtils, BoundedChannelCloseDrainsQueuedItems)
	TEST (ConcurrencyUtils, BoundedChannelTrySendAndTryRecv)
	TEST (ConcurrencyUtils, BoundedChannelCloseUnblocksSenderAndReceiver)
	TEST (ConcurrencyUtils, BoundedChannelProducerConsumerPreservesOrder)
	TEST (ConcurrencyUtils, BoundedChannelSupportsMoveOnlyPayloads)
	TEST (ConcurrencyUtils, BoundedChannelCancellationInterruptsBlockedSend)
	TEST (ConcurrencyUtils, BoundedChannelCancellationInterruptsBlockedRecv)
	TEST (ConcurrencyUtils, BoundedChannelCloseWinsIfOperationCanProceed)
	TEST (ConcurrencyUtils, BoundedChannelCancellationAppliesToEmplace)
	TEST (ConcurrencyUtils, BoundedChannelEmplaceAcceptsCancellationTokenPayloads)
	TEST (ConcurrencyUtils, BoundedChannelRecvUsesCopyFallbackForThrowingMoves)
	TEST (ConcurrencyUtils, BoundedChannelTryRecvPreservesQueuedValueOnAssignmentFailure)
	TEST (ConcurrencyUtils, SynchronizedWithLockAndGuard)
	TEST (ConcurrencyUtils, SynchronizedCounterUnderContention)
	TEST (ConcurrencyUtils, RwSynchronizedSupportsReadAndWriteAccess)
	TEST (ConcurrencyUtils, SynchronizedSupportsNonDefaultConstructibleValues)
	TEST (ConcurrencyUtils, RwSynchronizedSupportsNonDefaultConstructibleValues)
	TEST (ConcurrencyUtils, SpscQueueBasicPushPop)
	TEST (ConcurrencyUtils, SpscQueueProducerConsumerRoundTrip)
	TEST (ConcurrencyUtils, SpscQueueSupportsMoveOnlyValues)
	TEST (ConcurrencyUtils, SpscQueueTryPopUsesCopyFallbackForThrowingMoves)

Function Documentation

TEST() [1/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelCancellationAppliesToEmplace
	)

Definition at line 315 of file concurrency_utils_test.cc.

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

TEST() [2/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelCancellationInterruptsBlockedRecv
	)

Definition at line 267 of file concurrency_utils_test.cc.

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

TEST() [3/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelCancellationInterruptsBlockedSend
	)

Definition at line 235 of file concurrency_utils_test.cc.

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

TEST() [4/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelCloseDrainsQueuedItems
	)

Definition at line 125 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp().

TEST() [5/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelCloseUnblocksSenderAndReceiver
	)

Definition at line 160 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp().

TEST() [6/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelCloseWinsIfOperationCanProceed
	)

Definition at line 298 of file concurrency_utils_test.cc.

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

TEST() [7/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelEmplaceAcceptsCancellationTokenPayloads
	)

Definition at line 347 of file concurrency_utils_test.cc.

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

TEST() [8/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelProducerConsumerPreservesOrder
	)

Definition at line 195 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp().

TEST() [9/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelRecvUsesCopyFallbackForThrowingMoves
	)

Definition at line 365 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp().

TEST() [10/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelSupportsMoveOnlyPayloads
	)

Definition at line 223 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp().

TEST() [11/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelTryRecvPreservesQueuedValueOnAssignmentFailure
	)

Definition at line 380 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp().

TEST() [12/21]

TEST	(	ConcurrencyUtils	,
		BoundedChannelTrySendAndTryRecv
	)

Definition at line 145 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp().

TEST() [13/21]

TEST	(	ConcurrencyUtils	,
		RwSynchronizedSupportsNonDefaultConstructibleValues
	)

Definition at line 474 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::RwSynchronized< T, SharedMutex >::with_read_lock(), and Aleph::RwSynchronized< T, SharedMutex >::with_write_lock().

TEST() [14/21]

TEST	(	ConcurrencyUtils	,
		RwSynchronizedSupportsReadAndWriteAccess
	)

Definition at line 435 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::RwSynchronized< T, SharedMutex >::read(), Aleph::RwSynchronized< T, SharedMutex >::with_read_lock(), Aleph::RwSynchronized< T, SharedMutex >::with_write_lock(), and Aleph::RwSynchronized< T, SharedMutex >::write().

TEST() [15/21]

TEST	(	ConcurrencyUtils	,
		SpscQueueBasicPushPop
	)

Definition at line 487 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::SpscQueue< T >::empty(), Aleph::SpscQueue< T >::full(), Aleph::SpscQueue< T >::try_pop(), and Aleph::SpscQueue< T >::try_push().

TEST() [16/21]

TEST	(	ConcurrencyUtils	,
		SpscQueueProducerConsumerRoundTrip
	)

Definition at line 512 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::SpscQueue< T >::try_push().

TEST() [17/21]

TEST	(	ConcurrencyUtils	,
		SpscQueueSupportsMoveOnlyValues
	)

Definition at line 543 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::SpscQueue< T >::try_pop(), and Aleph::SpscQueue< T >::try_push().

TEST() [18/21]

TEST	(	ConcurrencyUtils	,
		SpscQueueTryPopUsesCopyFallbackForThrowingMoves
	)

Definition at line 555 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp(), Aleph::SpscQueue< T >::try_pop(), and Aleph::SpscQueue< T >::try_push().

TEST() [19/21]

TEST	(	ConcurrencyUtils	,
		SynchronizedCounterUnderContention
	)

Definition at line 418 of file concurrency_utils_test.cc.

References counter, and Aleph::divide_and_conquer_partition_dp().

TEST() [20/21]

TEST	(	ConcurrencyUtils	,
		SynchronizedSupportsNonDefaultConstructibleValues
	)

Definition at line 461 of file concurrency_utils_test.cc.

References Aleph::divide_and_conquer_partition_dp(), and Aleph::Synchronized< T, Mutex >::with_lock().

TEST() [21/21]

TEST	(	ConcurrencyUtils	,
		SynchronizedWithLockAndGuard
	)

Definition at line 397 of file concurrency_utils_test.cc.

References Aleph::copy(), Aleph::divide_and_conquer_partition_dp(), Aleph::Synchronized< T, Mutex >::lock(), and Aleph::Synchronized< T, Mutex >::with_lock().