UObjDeletionThread.h

/*
*  utilite is a cross-platform library with
*  useful utilities for fast and small developing.
*  Copyright (C) 2010  Mathieu Labbe
*
*  utilite is free library: you can redistribute it and/or modify
*  it under the terms of the GNU Lesser General Public License as published by
*  the Free Software Foundation, either version 3 of the License, or
*  (at your option) any later version.
*
*  utilite is distributed in the hope that it will be useful,
*  but WITHOUT ANY WARRANTY; without even the implied warranty of
*  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
*  GNU Lesser General Public License for more details.
*
*  You should have received a copy of the GNU Lesser General Public License
*  along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/
 
#ifndef UOBJDELETIONTHREAD_H
#define UOBJDELETIONTHREAD_H
 
#include "rtabmap/utilite/UThreadNode.h"
#include "rtabmap/utilite/UEvent.h"
#include "rtabmap/utilite/UEventsManager.h"
 
class UObjDeletedEvent : public UEvent
{
public:
  UObjDeletedEvent(int objDeletionThreadId) : UEvent(objDeletionThreadId) {}
  virtual ~UObjDeletedEvent() {}
  virtual std::string getClassName() const {return std::string("UObjDeletedEvent");}
};
 
template<class T>
class UObjDeletionThread : public UThread
{
public:
  UObjDeletionThread(T * obj, int id=0) :
    obj_(obj),
    id_(id),
    waitMs_(0) {}
 
  virtual ~UObjDeletionThread()
  {
    join(true);
    if(obj_)
    {
      delete obj_;
    }
  }
 
  void startDeletion(int waitMs = 0) {waitMs_ = waitMs; this->start();}
 
  int id() const {return id_;}
 
  void setObj(T * obj)
  {
    join();
    if(obj_)
    {
      delete obj_;
      obj_ = 0;
    }
    obj_ = obj;
  }
 
private:
  virtual void mainLoop()
  {
    if(waitMs_)
    {
      uSleep(waitMs_);
    }
    if(obj_)
    {
      delete obj_;
      obj_ = 0;
    }
    this->kill();
    UEventsManager::post(new UObjDeletedEvent(id_), false);
  }
 
private:
  T * obj_;
  int id_;
  int waitMs_;
};
 
#endif /* UOBJDELETIONTHREAD_H */