Channel added

Author: Vishnu Vijayan

core/include/Channel.h

@@ -38,15 +38,27 @@ namespace Core
 		{
 			this->mChannelStatus = CHANNEL_STATUS::CLOSED;
 		}
+
+		size_t size()
+		{
+			return this->mChannelData.size();
+		}
 		template <typename T1>
 		friend void operator<<(T1 &x, Channel<T1> &);
 	};
 
 	template <typename T>
 	void operator<<(T &x, Channel<T> &c)
 	{
-		c.mChannelData.pop(x, true);
+		if (c.mChannelStatus == CHANNEL_STATUS::OPEN)
+		{
+			if(!c.mChannelData.pop(x, true)) 
+			{
+				// throw exception here
+			}
+		}
 	}
+
 }
 
 #endif

main.cpp

@@ -93,14 +93,14 @@ int main()
 
 	for (int i = 0; i < 1000000; i++)
 	{
-		c << i;
+		c << rand() % 100;
 		async([&]()
 			  {
-				  int x;
+				  int x ;
 				  x << c;
-				  cout <<"Got from channel "<< x << endl;
+				  cout <<"Got from channel "<< x << " Channel size "<< c.size()<<endl;
 			  });
-		sleep(1);
+		usleep(1000);
 	}
 	/*
 	atexit(onExit);