/usr/share/doc/libcxxtools-dev/examples/thread.cpp

/*
 * Copyright (C) 2003 Tommi Maekitalo
 * 
 * This library is free software; 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 2.1 of the License, or (at your option) any later version.
 * 
 * As a special exception, you may use this file as part of a free
 * software library without restriction. Specifically, if other files
 * instantiate templates or use macros or inline functions from this
 * file, or you compile this file and link it with other files to
 * produce an executable, this file does not by itself cause the
 * resulting executable to be covered by the GNU General Public
 * License. This exception does not however invalidate any other
 * reasons why the executable file might be covered by the GNU Library
 * General Public License.
 * 
 * This library 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 library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 */

#include <cxxtools/function.h>
#include <cxxtools/thread.h>
#include <cxxtools/mutex.h>
#include <cxxtools/condition.h>
#include <iostream>
#include <string>
#include <unistd.h>

cxxtools::Mutex coutMutex;
cxxtools::Mutex conditionMutex;
cxxtools::Condition running;

#define PRINTLN(expr) \
  do { \
    cxxtools::MutexLock lock(coutMutex); \
    std::cout << time(0) << ' ' << expr << std::endl; \
  } while (false)

class myDetachedThread : public cxxtools::DetachedThread
{
    ~myDetachedThread();

  protected:
    void run();
};

myDetachedThread::~myDetachedThread()
{
  PRINTLN("myDetachedThread::~myDetachedThread() called");
}

void myDetachedThread::run()
{
  PRINTLN("myDetachedThread is starting");

  cxxtools::MutexLock lock(conditionMutex);
  running.broadcast();
  lock.unlock();

  ::sleep(1);
  PRINTLN("myDetachedThread waits");
  ::sleep(2);
  PRINTLN("myDetachedThread is ready");
}

void someFunction()
{
  PRINTLN("someFunction()");
  ::sleep(1);
  PRINTLN("someFunction() ends");
}

class AClass
{
    std::string id;

  public:
    AClass(const std::string& id_)
      : id(id_)
      { }
    ~AClass()
      { PRINTLN("AClass::~AClass of object \"" << id << '"'); }

    void run()
    {
      PRINTLN("aFunction() of object \"" << id << '"');
      ::sleep(1);
      PRINTLN("aFunction() of object \"" << id << "\" ends");
    }
};

int main()
{
  try
  {
    cxxtools::MutexLock lock(conditionMutex);

    // detached threads are created on the heap.
    // They are deleted automatically when the thread ends.
    cxxtools::Thread* d = new myDetachedThread;
    d->create();
    running.wait(lock);
    PRINTLN("myDetachedThread is running");

    // run a function as a attached thread
    cxxtools::AttachedThread th( cxxtools::callable(someFunction) );
    th.start();

    // run a method of a object as a thread
    AClass aInstance("a instance");
    AClass aInstance2("a instance 2");
    cxxtools::AttachedThread aclassThread( cxxtools::callable(aInstance, &AClass::run) );
    cxxtools::AttachedThread aclassThread2( cxxtools::callable(aInstance2, &AClass::run) );
    aclassThread.start();
    aclassThread2.start();
    ::sleep(2);
    aclassThread.join();
    aclassThread2.join();

    // The detached thread is killed, if it does not come to an end before main.
    // The attached thread blocks the main-program, until it is ready.
    PRINTLN("main stops");
  }
  catch (const std::exception& e)
  {
    std::cerr << "ERROR: " << e.what() << std::endl;
  }

  std::cout << "main stopped" << std::endl;
}
libcxxtools-dev 2.0-4ubuntu2 / usr / share / doc / libcxxtools-dev / examples / thread.cpp
