Ichthyostega
7448b81d49
This is a collection with unique-ownership, and the ability to create all content objects in ''RAII style'' from the constructor call, using a ''population functor''. It is often used to maintain a collection of resource handles, and especially to start a series of threads (for testing). With the variadic λ-captures from C++20, it is possible to rewrite the most frequently used population functors to be easier to use. Notably we can now bind constructor arguments, that will be passed to each of the created elements — a prominent example being the thread function when launching several threads. Furthermore, I added a constructor variant that consumes a Lumiera Iterator. Adding this kind of generic variants is possible now with C++20, since overload resolution takes concepts into account.
98 lines
3.3 KiB
C++
98 lines
3.3 KiB
C++
/*
|
||
SyncClasslock(Test) - validate the type-based Monitor locking
|
||
|
||
Copyright (C)
|
||
2008, Hermann Vosseler <Ichthyostega@web.de>
|
||
|
||
**Lumiera** is free software; you can redistribute it and/or modify it
|
||
under the terms of the GNU General Public License as published by the
|
||
Free Software Foundation; either version 2 of the License, or (at your
|
||
option) any later version. See the file COPYING for further details.
|
||
|
||
* *****************************************************************/
|
||
|
||
/** @file sync-classlock-test.cpp
|
||
** unit test \ref SyncClasslock_test
|
||
*/
|
||
|
||
|
||
#include "test/run.hpp"
|
||
#include "lib/sync-classlock.hpp"
|
||
#include "lib/scoped-collection.hpp"
|
||
#include "lib/iter-explorer.hpp"
|
||
#include "lib/thread.hpp"
|
||
|
||
using test::Test;
|
||
using lib::explore;
|
||
using std::this_thread::yield;
|
||
|
||
namespace lib {
|
||
namespace test {
|
||
|
||
namespace { // Parameters for multithreaded contention test
|
||
|
||
const uint NUM_THREADS = 20; ///< number of contending threads to create
|
||
const uint NUM_LOOP = 1000; ///< number of loop iterations per thread
|
||
|
||
}
|
||
|
||
|
||
|
||
|
||
/**********************************************************************//**
|
||
* @test check proper handling of class (not instance)-based Monitor locks.
|
||
* Because no instance is available in this case, a hidden storage for the
|
||
* Monitor object needs to be provided in a way safe for use even in the
|
||
* static startup/shutdown phase. This can not directly validate this
|
||
* allocation of a shared monitor object behind the scenes, but it
|
||
* can verify the monitor is indeed shared by all ClassLock instances
|
||
* templated to a specific type.
|
||
*
|
||
* @see sync.hpp
|
||
*/
|
||
class SyncClasslock_test : public Test
|
||
{
|
||
|
||
virtual void
|
||
run (Arg)
|
||
{
|
||
seedRand();
|
||
auto gen = buildCappedSubSequence(defaultGen);
|
||
int contended = 0;
|
||
|
||
using Threads = lib::ScopedCollection<Thread>;
|
||
|
||
Threads threads{NUM_THREADS,
|
||
// Start a bunch of threads with random access pattern...
|
||
Threads::fill ("Sync-ClassLock stress test"
|
||
,[&]{
|
||
for (uint i=0; i<NUM_LOOP; ++i)
|
||
{
|
||
uint delay = gen.i(10);
|
||
usleep (delay);
|
||
{
|
||
ClassLock<void> guard;
|
||
++contended;
|
||
}
|
||
}
|
||
})};
|
||
|
||
while (explore(threads).has_any())
|
||
yield(); // wait for all threads to terminate
|
||
|
||
CHECK (contended == NUM_THREADS * NUM_LOOP,
|
||
"ALARM: Lock failed, concurrent modification "
|
||
"during counter increment. Delta == %d"
|
||
,NUM_THREADS * NUM_LOOP - contended);
|
||
}
|
||
|
||
};
|
||
|
||
|
||
|
||
/** Register this test class... */
|
||
LAUNCHER (SyncClasslock_test, "unit common");
|
||
|
||
|
||
|
||
}} // namespace lib::test
|