]> git.sesse.net Git - casparcg/blobdiff - common/blocking_priority_queue.h
[ffmpeg_producer] Add relative and "from end" seeking
[casparcg] / common / blocking_priority_queue.h
index 7fd7e19fd3b4843e625ec7fbb34cbbc1d10de6b8..33c5b989b61177213d0a55c70d6738e85283fc5d 100644 (file)
@@ -45,11 +45,11 @@ class blocking_priority_queue
 public:
        typedef unsigned int size_type;
 private:       
-       std::map<Prio, tbb::concurrent_queue<T>, std::greater<Prio>> queues_by_priority_;
-       semaphore space_available_;
-       semaphore elements_available_;
-       mutable boost::mutex capacity_mutex_;
-       size_type capacity_;
+       std::map<Prio, tbb::concurrent_queue<T>, std::greater<Prio>>    queues_by_priority_;
+       size_type                                                                                                               capacity_;
+       semaphore                                                                                                               space_available_        { capacity_ };
+       semaphore                                                                                                               elements_available_     { 0u };
+       mutable boost::mutex                                                                                    capacity_mutex_;
 public:
        /**
         * Constructor.
@@ -60,9 +60,7 @@ public:
         */
        template<class PrioList>
        blocking_priority_queue(size_type capacity, const PrioList& priorities)
-               : space_available_(capacity)
-               , elements_available_(0u)
-               , capacity_(capacity)
+               : capacity_(capacity)
        {
                for (Prio priority : priorities)
                {