Method run

lib_fiber/samples-c++/pgsql/main.cpp:154–177

@override

protected:
	// @override
	void run(void)
	{
//		printf("fiber-%d-%d running\r\n", get_id(), acl::fiber::self());
		acl_fiber_delay(10);

		pgsql_oper dboper(dbp_, id_);

		if (oper_.equal("add", false))
			dboper.pgsql_add(count_);
		else if (oper_.equal("get", false))
			dboper.pgsql_get(count_);
		else
			printf("unknown command: %s\r\n", oper_.c_str());

		delete this;

		printf("----__cur_fibers: %d----\r\n", __cur_fibers);

		if (--__cur_fibers == 0)
		{
			printf("All fibers Over\r\n");
			acl::fiber::schedule_stop();
		}
	}

private:
	int id_;