Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class Consumer {
- public:
- Consumer(MyQueue& queue, Producer& producer) : my_queue(queue), used_producer(producer) {
- }
- void consume() {
- while ((my_queue.size() > 0) || used_producer.is_active()) {
- std::optional<element> popped_element = my_queue.pop();
- if (popped_element.has_value()) {
- element popped_value = popped_element.value();
- std::sort(popped_value.begin(), popped_value.end());
- sorted_elements++;
- //std::cout << popped_value[0] << "," << popped_value[1] << "," << popped_value[2] << "," << popped_value[3] << "," << popped_value[4] << std::endl;
- }
- }
- std::cout << "Sorted elements: " << sorted_elements << std::endl;
- }
- private:
- MyQueue& my_queue;
- int sorted_elements = 0;
- Producer used_producer;
- };
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement