Method trigger

lib_acl_cpp/src/stream/aio_timer_callback.cpp:162–234

}

acl_int64 aio_timer_callback::trigger()
{
	// sanity check
	if (tasks_.empty()) {
		return TIMER_EMPTY;
	}

	acl_assert(length_ > 0);

	set_time();

	std::list<aio_timer_task*>::iterator it;
	std::list<aio_timer_task*> tasks;
	aio_timer_task* task;

	// �Ӷ�ʱ����ȡ������Ķ�ʱ����
	for (it = tasks_.begin(); it != tasks_.end();) {
		if ((*it)->when > present_) {
			break;
		}
		task = *it;
		it = tasks_.erase(it);
		length_--;
		tasks.push_back(task);
	}

	// �п�����Щ����Ķ�ʱ�����Ѿ����û���ǰɾ����
	if (tasks.empty()) {
		acl_assert(!tasks_.empty());

		aio_timer_task* first = tasks_.front();
		acl_int64 delay = first->when - present_;
		return delay < 0 ? 0 : delay;
	}

	// ������Ķ�ʱ�������·Ż�����ʱ���������б��У�
	// ����ʼ�������еĵ���Ķ�ʱ����

	// ���������ô�������æ״̬���Է�ֹ�����ڻص�����
	// �е����˸���������������
	set_locked();

	// ���ý��������ٱ�־Ϊ false����Ϊ��ǰ�ö�ʱ������
	// ����״̬�����������������ֱ��������ʱ���ٱ���
	// ���󣬵�����������ñ�ʶ����Ϊ true���������
	// Ӧ���Զ�����
	destroy_on_unlock_ = false;

	for (it = tasks.begin(); it != tasks.end(); ++it) {
		set_task(*it);
		timer_callback((*it)->id);
	}

	tasks.clear();

	// ����֮��IJ����б����������������
	unset_locked();