Method add

lib_fiber/cpp/src/wait_group.cpp:18–58

}

void wait_group::add(int n)
{
	long long state = state_.add_fetch((long long)n << 32);

	// The high 32 bits store the number of tasks.
	int c = (int)(state >> 32);

	// The low 32 bits store the number of waiters.
	unsigned w =  (unsigned)state;

	// count must be >= 0.
	if (c < 0){
		logger_fatal("Negative wait_group counter, c=%d", c);
	}

	if (w != 0 && n > 0 && c == n){
		logger_fatal("Add called concurrently with wait");
	}

	if (c > 0 || w == 0) {
		return;
	}

	// Check if the state has been changed.
	if (state_ != state) {
		logger_fatal("Add called concurrently with wait");
	}

	// The count should be zero, so clear state and wakeup all the waiters.
	state_ = 0;

	for (size_t i = 0; i < w; i++) {
#ifdef	_DEBUG
		unsigned long* tid = new unsigned long;
		*tid = acl::thread::self();
		box_->push(tid);
#else
		box_->push(NULL);
#endif
	}
}

void wait_group::done()
{