concurrent_queue テンプレート・クラス

概要

並列操作を含むキュー用のテンプレート・クラス。

構文

template<typename T, typename Alloc=cache_aligned_allocator<T> >
class concurrent_queue;

ヘッダー

#include "tbb/concurrent_queue.h"

説明

concurrent_queue は、複数のスレッドがアイテムのプッシュとポップを同時に行うことができる FIFO (先入れ先出し) データ構造です。大きさは無制限で、対象のマシン上のメモリー制限に従います。

インターフェイスは、同時変更を安全に行えるようにしている点を除いて、STL std::queue に似ています。

メンバー

namespace tbb {
    template<typename T, typename A = cache_aligned_allocator<T> >
    class concurrent_queue {
    public:
        // 型
        typedef T value_type;
        typedef T& reference;
        typedef const T& const_reference;
        typedef std::size_t size_type;
        typedef std::ptrdiff_t difference_type;
        typedef A allocator_type;

        explicit concurrent_queue( const allocator_type& a = allocator_type() );
        concurrent_queue( const concurrent_queue& src, const allocator_type& a = allocator_type() );
        template<typename InputIterator>
        concurrent_queue( InputIterator first, InputIterator last, const allocator_type& a = allocator_type() );
        // C++11 仕様
        concurrent_queue( concurrent_queue&& src );
        concurrent_queue( concurrent_queue&& src, const allocator_type& a );

        ~concurrent_queue();

        void push( const T& source );
        bool try_pop( T& destination );
        // C++11 仕様
        void push( T&& source );
        template<typename... Args>
        void emplace(Args&&... args);

        void clear();

        size_type unsafe_size() const;
        bool empty() const;
        allocator_type get_allocator() const;

        typedef implementation-defined iterator;
        typedef implementation-defined const_iterator;

        // イテレーター (低速、デバッグ用)
        iterator unsafe_begin();
        iterator unsafe_end();
        const_iterator unsafe_begin() const;
        const_iterator unsafe_end() const;
    };
}
      

例外の安全性

concurrent_queue クラスは、次の例外の安全性を保証します。

• コンストラクターの push および無指定の try_pop メソッドで、構築中またはデータアイテムのコピー中に例外がスローされた場合:

  • キューは有効なままです。同じキューの同時処理操作および将来の操作は影響を受けません。

  • コンストラクターや push によって追加されるデータアイテム、および try_pop によって削除されるデータアイテムは失われます。

• concurrent_queue のほかのすべてのメソッドは例外をスローしません。

これらは、T 型のデストラクターが例外をスローしない場合のみ保証されます。その他の場合、動作は不定です。

イテレーター

concurrent_queue は、単独でプログラマーがデバッグ中にキューを検査できるように制限付きのイテレーター・サポートを提供します。iterator 型および const_iterator 型を提供します。どちらも、前方イテレーター用の通常の STL 規則に従います。反復順は、以前プッシュされたものから最近プッシュされたものの順になります。変更すると、concurrent_queue を参照するすべてのイテレーターが無効になります。

サンプル

次のプログラムは、整数 0..9 でキューを構築した後、キューを標準出力にダンプします。その結果、0 1 2 3 4 5 6 7 8 9 が出力されます。

#include "tbb/concurrent_queue.h"
#include <iostream>

using namespace std;
using namespace tbb;

int main() {
    concurrent_queue<int> queue;
    for( int i=0; i<10; ++i )
        queue.push(i);
    typedef concurrent_queue<int>::iterator iter;
    for( iter i(queue.unsafe_begin()); i!=queue.unsafe_end(); ++i )
        cout << *i << " ";
    cout << endl;
    return 0;
}