Method run

lib_acl_cpp/samples/thread_queue/main.cpp:105–117

protected:
	void* run()
	{
		for (int i = 0; i < max_; i++)
		{
			queue_item* item = new queue_item(MSG_ECHO);
			queue_.push(item);
		}
		printf("push msg ok\r\n");

		queue_item* item = new queue_item(MSG_STOP);
		queue_.push(item);
		return NULL;
	}

private:
	acl::thread_queue& queue_;