Files

Pipeline.h

#pragma once

#include "stdafx.h"

/**
 *   A pipeline is a simple comunication channel between two threads,
 *   one writes to the pipeline while another reads
 */
class Pipeline {
public:
	Pipeline();
	void write( double value );
	double read();
private:
	bool empty;
	double value;
	/*  Mutex to coordinate threads */
	std::mutex mtx;
	/* Condition variable to signal between threads */
	std::condition_variable cv;	
};


void testPipeline();