[RESOLVED] Two-way event-driven communication between objects (similar to producer-consumer)

[vincegata]

Hi,

I need to implement a two-way asynchronous communication between two objects, not using any IPC.

What I have now is a producer-consumer model where producer sends a number "88" to consumer at random intervals. Now, I need consumer to send a number "99" back to producer at a random intervals, this probably should be done in a separate thread. My prototype could be totally wrong for what I need hence I am open to any suggestions. I'd appreciate any help, thank you.

I am using GNU on Linux, here is the compile line.

g++ -g -std=c++11 main.cpp -o main

#include<iostream>
#include<chrono>
#include<thread>

class IObject
{
	public:
	virtual void fromApp(int i) = 0;
 	virtual int toApp(int& i) = 0;			// ???
};

class Producer
{
	private:
	IObject& obj;

	public:
	Producer(IObject& p) : obj(p) { }
	void run() { while(1) {int d=rand()%500+100; std::this_thread::sleep_for(std::chrono::milliseconds(d)); obj.fromApp(88);} }	// Generate and send data.
};

class Consumer : public IObject
{
	public:
	void fromApp(int i) { std::cout << i*10 << std::endl; }		// Process data.
	int toApp(int& i) {while(1) {int d=rand()%500+100; std::this_thread::sleep_for(std::chrono::milliseconds(d)); i = 99;} }
};

int main()
{
	Consumer cons;
	Producer prod(cons);
	prod.run();
}