forked from boostorg/smart_ptr
123 lines
2.6 KiB
C++
123 lines
2.6 KiB
C++
#include <boost/config.hpp>
|
|
|
|
#if defined(BOOST_MSVC)
|
|
#pragma warning(disable: 4786) // identifier truncated in debug info
|
|
#pragma warning(disable: 4710) // function not inlined
|
|
#pragma warning(disable: 4711) // function selected for automatic inline expansion
|
|
#pragma warning(disable: 4514) // unreferenced inline removed
|
|
#endif
|
|
|
|
// weak_ptr_mt_test.cpp
|
|
//
|
|
// Copyright (c) 2002 Peter Dimov and Multi Media Ltd.
|
|
// Copyright 2005, 2008 Peter Dimov
|
|
//
|
|
// Distributed under the Boost Software License, Version 1.0.
|
|
// See accompanying file LICENSE_1_0.txt or copy at
|
|
// http://www.boost.org/LICENSE_1_0.txt
|
|
|
|
#include <boost/shared_ptr.hpp>
|
|
#include <boost/weak_ptr.hpp>
|
|
#include <boost/bind.hpp>
|
|
|
|
#include <vector>
|
|
|
|
#include <cstdio>
|
|
#include <ctime>
|
|
#include <cstdlib>
|
|
|
|
#include <boost/detail/lightweight_thread.hpp>
|
|
|
|
//
|
|
|
|
int const n = 16384;
|
|
int const k = 512; // vector size
|
|
int const m = 16; // threads
|
|
|
|
void test( std::vector< boost::shared_ptr<int> > & v )
|
|
{
|
|
using namespace std; // printf, rand
|
|
|
|
std::vector< boost::weak_ptr<int> > w( v.begin(), v.end() );
|
|
|
|
int s = 0, f = 0, r = 0;
|
|
|
|
for( int i = 0; i < n; ++i )
|
|
{
|
|
// randomly kill a pointer
|
|
|
|
v[ rand() % k ].reset();
|
|
++s;
|
|
|
|
for( int j = 0; j < k; ++j )
|
|
{
|
|
if( boost::shared_ptr<int> px = w[ j ].lock() )
|
|
{
|
|
++s;
|
|
|
|
if( rand() & 4 )
|
|
{
|
|
continue;
|
|
}
|
|
|
|
// rebind anyway with prob. 50% for add_ref_lock() against weak_release() contention
|
|
++f;
|
|
}
|
|
else
|
|
{
|
|
++r;
|
|
}
|
|
|
|
w[ j ] = v[ rand() % k ];
|
|
}
|
|
}
|
|
|
|
printf( "\n%d locks, %d forced rebinds, %d normal rebinds.", s, f, r );
|
|
}
|
|
|
|
#if defined( BOOST_HAS_PTHREADS )
|
|
|
|
char const * thmodel = "POSIX";
|
|
|
|
#else
|
|
|
|
char const * thmodel = "Windows";
|
|
|
|
#endif
|
|
|
|
int main()
|
|
{
|
|
using namespace std; // printf, clock_t, clock
|
|
|
|
printf("Using %s threads: %d threads, %d * %d iterations: ", thmodel, m, n, k );
|
|
|
|
std::vector< boost::shared_ptr<int> > v( k );
|
|
|
|
for( int i = 0; i < k; ++i )
|
|
{
|
|
v[ i ].reset( new int( 0 ) );
|
|
}
|
|
|
|
clock_t t = clock();
|
|
|
|
boost::detail::lw_thread_t a[ m ];
|
|
|
|
for( int i = 0; i < m; ++i )
|
|
{
|
|
boost::detail::lw_thread_create( a[ i ], boost::bind( test, v ) );
|
|
}
|
|
|
|
v.resize( 0 ); // kill original copies
|
|
|
|
for( int j = 0; j < m; ++j )
|
|
{
|
|
boost::detail::lw_thread_join( a[j] );
|
|
}
|
|
|
|
t = clock() - t;
|
|
|
|
printf("\n\n%.3f seconds.\n", static_cast<double>(t) / CLOCKS_PER_SEC);
|
|
|
|
return 0;
|
|
}
|