block_queue.hpp File Reference

#include <thrill/common/atomic_movable.hpp>
#include <thrill/common/concurrent_bounded_queue.hpp>
#include <thrill/common/stats_timer.hpp>
#include <thrill/data/block.hpp>
#include <thrill/data/block_reader.hpp>
#include <thrill/data/block_writer.hpp>
#include <thrill/data/dyn_block_reader.hpp>
#include <thrill/data/file.hpp>
#include <atomic>

Include dependency graph for block_queue.hpp:

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

Go to the source code of this file.

Classes
class	BlockQueue
	A BlockQueue is a thread-safe queue used to hand-over Block objects between threads. More...
class	BlockQueueSink
	BlockSink which interfaces to a File. More...
class	CacheBlockQueueSource
	A BlockSource to read Blocks from a BlockQueue using a BlockReader, and at the same time CACHE all items received. More...
class	ConsumeBlockQueueSource
	A BlockSource to read Block from a BlockQueue using a BlockReader. More...

Namespaces
	thrill
	thrill::data

Macros
#define	THRILL_DATA_BLOCK_QUEUE_HEADER

Macro Definition Documentation

THRILL_DATA_BLOCK_QUEUE_HEADER

#define THRILL_DATA_BLOCK_QUEUE_HEADER

Definition at line 14 of file block_queue.hpp.