queue.hh

Go to the documentation of this file.

/*
 * Scroom - Generic viewer for 2D data
 * Copyright (C) 2009-2026 Kees-Jan Dijkzeul
 *
 * SPDX-License-Identifier: LGPL-2.1
 */
 
#pragma once
 
#include <scroom/threadpool.hh>
 
namespace Scroom::Detail::ThreadPool
{
  class QueueImpl
  {
  public:
    using Ptr = std::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