view Core/MultiThreading/ArrayFilledByThreads.h @ 724:96a2d2da0fee

more sqlite tests
author Sebastien Jodogne <s.jodogne@gmail.com>
date Tue, 18 Feb 2014 16:55:10 +0100
parents 0da078f3affc
children
line wrap: on
line source

#pragma once

#include <boost/thread.hpp>

#include "../IDynamicObject.h"

namespace Orthanc
{
  class ArrayFilledByThreads
  {
  public:
    class IFiller
    {
    public:
      virtual size_t GetFillerSize() = 0;

      virtual IDynamicObject* GetFillerItem(size_t index) = 0;
    };

  private:
    IFiller& filler_;
    boost::mutex  mutex_;
    std::vector<IDynamicObject*>  array_;
    bool filled_;
    unsigned int threadCount_;

    class Command;

    void Clear();

    void Update();

  public:
    ArrayFilledByThreads(IFiller& filler);

    ~ArrayFilledByThreads();
  
    void Reload();

    void Invalidate();

    void SetThreadCount(unsigned int t);

    unsigned int GetThreadCount() const
    {
      return threadCount_;
    }

    size_t GetSize();

    IDynamicObject& GetItem(size_t index);
  };
}