queue.hh

Go to the documentation of this file.

/*
 * Scroom - Generic viewer for 2D data
 * Copyright (C) 2009-2022 Kees-Jan Dijkzeul
 *
 * SPDX-License-Identifier: LGPL-2.1
 */
 
#pragma once
 
#include <scroom/threadpool.hh>
 
namespace Scroom::Detail::ThreadPool
{
  class QueueImpl
  {
  public:
    using Ptr = boost::shared_ptr<QueueImpl>;
 
    static Ptr create();
 
    bool jobStarted();
 
    void jobFinished();
 
    void deletingQueue();
 
    int getCount();
 
  private:
    boost::mutex              mut;              
    boost::condition_variable cond;             
    unsigned int              count{0};         
    bool                      isDeleted{false}; 
  private:
    QueueImpl() = default;
  };
 
  class QueueLock
  {
    QueueImpl::Ptr q;       
    bool           isValid; 
  public:
    explicit QueueLock(QueueImpl::Ptr queue);
    QueueLock(const QueueLock&)            = delete;
    QueueLock(QueueLock&&)                 = delete;
    QueueLock& operator=(const QueueLock&) = delete;
    QueueLock& operator=(QueueLock&&)      = delete;
    ~QueueLock();
 
    [[nodiscard]] bool queueExists() const;
  };
 
} // namespace Scroom::Detail::ThreadPool