C++ 安全并发访问容器元素

标签：并发   concurrency   线程安全   parallel   

effective STL给出的Lock框架

template<typename Container> //一个为容器获取和释放互斥体的模板  
class Lock
{ //框架；其中的很多细节被省略了  
public:
	Lock(const Container& container) :c(container) 
	{  
		getMutexFor(c); 
		//在构造函数中获取互斥体 
	} 
	~Lock() 
	{   
		releaseMutexFor(c); 
		//在析构函数中释放它
	} 
private: const Container& c; 
};  

// parallel-fibonacci.cpp
// compile with: /EHsc
#include <windows.h>
#include <ppl.h>
#include <concurrent_vector.h>
#include <array>
#include <vector>
#include <tuple>
#include <algorithm>
#include <iostream>


using namespace Concurrency;
using namespace std;


// Calls the provided work function and returns the number of milliseconds 
// that it takes to call that function.
template <class Function>
__int64 time_call(Function&& f)
{
   __int64 begin = GetTickCount();
   f();
   return GetTickCount() - begin;
}


// Computes the nth Fibonacci number.
int fibonacci(int n)
{
   if(n < 2)
      return n;
   return fibonacci(n-1) + fibonacci(n-2);
}


int wmain()
{
   __int64 elapsed;


   // An array of Fibonacci numbers to compute.
   array<int, 4> a = { 24, 26, 41, 42 };


   // The results of the serial computation.
   vector<tuple<int,int>> results1;


   // The results of the parallel computation.
   concurrent_vector<tuple<int,int>> results2;


   // Use the for_each algorithm to compute the results serially.
   elapsed = time_call([&] 
   {
      for_each (a.begin(), a.end(), [&](int n) {
         results1.push_back(make_tuple(n, fibonacci(n)));
      });
   });   
   wcout << L"serial time: " << elapsed << L" ms" << endl;


   // Use the parallel_for_each algorithm to perform the same task.
   elapsed = time_call([&] 
   {
      parallel_for_each (a.begin(), a.end(), [&](int n) {
         results2.push_back(make_tuple(n, fibonacci(n)));
      });


      // Because parallel_for_each acts concurrently, the results do not 
      // have a pre-determined order. Sort the concurrent_vector object
      // so that the results match the serial version.
      sort(results2.begin(), results2.end());
   });   
   wcout << L"parallel time: " << elapsed << L" ms" << endl << endl;


   // Print the results.
   for_each (results2.begin(), results2.end(), [](tuple<int,int>& pair) {
      wcout << L"fib(" << get<0>(pair) << L"): " << get<1>(pair) << endl;
   });
}

#include "stdafx.h"
#include <ppl.h>
#include <array>
#include <iostream>
using namespace Concurrency;
using namespace std;
using namespace std::tr1;


// Function object (functor) class that computes the square of its input.
template<class Ty>
class SquareFunctor
{
public:
	void operator()(Ty& n) const
	{
		n *= n;
	}
};


// Function that computes the square of its input.
template<class Ty>
void square_function(Ty& n)
{
	n *= n;
}
int _tmain(int argc, _TCHAR* argv[])
{
	// Create an array object that contains 5 values.
	array<int, 5> values = { 1, 2, 3, 4, 5 };


	// Use a lambda function, a function object, and a function pointer to 
	// compute the square of each element of the array in parallel.


	// Use a lambda function to square each element.
	parallel_for_each(values.begin(), values.end(), [](int& n){n *= n;});


	// Use a function object (functor) to square each element.
	parallel_for_each(values.begin(), values.end(), SquareFunctor<int>());


	// Use a function pointer to square each element.
	parallel_for_each(values.begin(), values.end(), &square_function<int>);


	// Print each element of the array to the console.
	for_each(values.begin(), values.end(), [](int& n) { 
		wcout << n << endl;
	});
	return 0;
}

#include <boost/thread/thread.hpp>
#include <boost/lockfree/queue.hpp>
#include <iostream>


#include <boost/atomic.hpp>


boost::atomic_int producer_count(0);
boost::atomic_int consumer_count(0);


boost::lockfree::queue<int> queue(128);


const int iterations = 10000000;
const int producer_thread_count = 4;
const int consumer_thread_count = 4;


void producer(void)
{
    for (int i = 0; i != iterations; ++i) {
        int value = ++producer_count;
        while (!queue.push(value))
            ;
    }
}


boost::atomic<bool> done (false);
void consumer(void)
{
    int value;
    while (!done) {
        while (queue.pop(value))
            ++consumer_count;
    }


    while (queue.pop(value))
        ++consumer_count;
}


int main(int argc, char* argv[])
{
    using namespace std;
    cout << "boost::lockfree::queue is ";
    if (!queue.is_lock_free())
        cout << "not ";
    cout << "lockfree" << endl;


    boost::thread_group producer_threads, consumer_threads;


    for (int i = 0; i != producer_thread_count; ++i)
        producer_threads.create_thread(producer);


    for (int i = 0; i != consumer_thread_count; ++i)
        consumer_threads.create_thread(consumer);


    producer_threads.join_all();
    done = true;


    consumer_threads.join_all();


    cout << "produced " << producer_count << " objects." << endl;
    cout << "consumed " << consumer_count << " objects." << endl;
}

C++ 安全并发访问容器元素

标签：并发   concurrency   线程安全   parallel   

原文地址：http://blog.csdn.net/flyfish1986/article/details/39526251