mix_block_queue.hpp File Reference

#include <thrill/common/atomic_movable.hpp>
#include <thrill/common/concurrent_bounded_queue.hpp>
#include <thrill/common/logger.hpp>
#include <thrill/data/block.hpp>
#include <thrill/data/block_queue.hpp>
#include <thrill/data/block_reader.hpp>
#include <thrill/data/cat_block_source.hpp>
#include <thrill/data/dyn_block_reader.hpp>
#include <thrill/data/file.hpp>
#include <vector>

Include dependency graph for mix_block_queue.hpp:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	MixBlockQueue
	Implements reading an unordered sequence of items from multiple workers, which sends Blocks. More...
struct	MixBlockQueue::SrcBlockPair
	pair of (source worker, Block) stored in the main mix queue. More...
class	MixBlockQueueReader
	Reader to retrieve items in unordered sequence from a MixBlockQueue. More...

Namespaces
	thrill
	thrill::data

Macros
#define	THRILL_DATA_MIX_BLOCK_QUEUE_HEADER

Typedefs
using	MixStreamDataPtr = tlx::CountingPtr< MixStreamData >

Macro Definition Documentation

THRILL_DATA_MIX_BLOCK_QUEUE_HEADER

#define THRILL_DATA_MIX_BLOCK_QUEUE_HEADER

Definition at line 13 of file mix_block_queue.hpp.