Commitd79a27c

committed

raise queue event only if queue was empty

1 parent2869882 commitd79a27cCopy full SHA for d79a27c

File tree

-3

lines changed

-3

lines changed

Lines changed: 4 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,9 @@ class queue {`
`58`	`58`	`returnnullptr;`
`59`	`59`	`}`
`60`	`60`
`61`		`-voidpush(T*const node) {`
	`61`	`+/// @brief Appends a node in the queue.`
	`62`	`+/// @returns true if the queue was empty.`
	`63`	`+boolpush(T*const node) {`
`62`	`64`	`std::lock_guardg(mutex_);`
`63`	`65`
`64`	`66`	`if (tail_) {`
`@@ -68,6 +70,7 @@ class queue {`
`68`	`70`	`node->next = node;`
`69`	`71`	`}`
`70`	`72`	`tail_ = node;`
	`73`	`+return node->next == node;`
`71`	`74`	`}`
`72`	`75`
`73`	`76`	`T*pop() {`

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -452,8 +452,9 @@ object_t* runtime_t::pop_object() {`
`452`	`452`	`}`
`453`	`453`
`454`	`454`	`voidruntime_t::push_object(object_t*const obj) {`
`455`		`- queue_.push(obj);`
`456`		`- queue_event_.signaled();`
	`455`	`+if (queue_.push(obj)) {`
	`456`	`+ queue_event_.signaled();`
	`457`	`+ }`
`457`	`458`	`}`
`458`	`459`
`459`	`460`	`}// namespace acto::core`

Comments

(0)