Method run

lib_acl_cpp/samples/thread_queue/main.cpp:39–91

protected:
	void* run()
	{
		long long int  n = 0;

		struct timeval begin;
		gettimeofday(&begin, NULL);

		while (true)
		{
			queue_item* item = (queue_item*) queue_.pop();
			if (item == NULL)
				break;

			n++;

			msg_t type = item->get_type();
			delete item;

			if (type == MSG_STOP)
			{
				printf("stop now, max: %lld\r\n", n);
				break;
			}

			switch (type)
			{
			case MSG_ECHO:
				if (n <= 10)
					printf("hello\r\n");
				if (n % 100000 == 0)
				{
					char tmp[256];
					acl::safe_snprintf(tmp, sizeof(tmp),
						"n: %lld", n);
					acl::meter_time(__FILE__, __LINE__, tmp);
				}
				break;
			default:
				printf("unknown msg type\r\n");
				break;
			}
		}

		struct timeval end;
		gettimeofday(&end, NULL);
		double spent = util::stamp_sub(&end, &begin);

		printf("queue item over, max: %lld\r\n", n);
		printf("max: %lld, spent: %.2f, speed: %.2f\r\n",
			n, spent, n * 1000 / (spent > 0 ? spent : 1));

		return NULL;
	}

private:
	acl::thread_queue& queue_;