#include "NetWay/BlockingQueue.h"
#include <iostream>
#include <string>
#include <windows.h>


using namespace std;

NetWay::BlockingQueue<string> bq;

DWORD WINAPI ThreadFunc(LPVOID lpParam)
{
	int* n = (int *)lpParam;
	printf("Thread %d is waiting/n",n);
	string str = bq.take();
	printf("Thread %d got an element:%s /n",n,str.c_str());

	return 0;
}

void main()
{	
	DWORD dlen;
	for(int i = 0; i < 5; i++)
	{
		CreateThread(NULL,0,ThreadFunc,(LPVOID)i,0,&dlen);
	}

	Sleep(2*1000);  // all threads are waiting.
	
	bq.enqueue("1");
	bq.enqueue("2");
	bq.enqueue("3");

	Sleep(3*1000); // still 2 threads are waiting.

	bq.enqueue("4");

	Sleep(2*1000); // only 1 thread is waiting

	printf("now the main thread is trying to poll an element/n");

	try 
	{
		bq.poll(3*1000);
	}catch(...)
	{
		printf("poll time out.");
	}

	cin>>dlen;

}

代码可随意修改，转帖请注明出处。