Poco

template < class C >

class Activity

File Information

Library: Foundation
Package: Threading
Header: Poco/Activity.h

Description

This template class helps to implement active objects. An active object uses threads to decouple method execution from method invocation, or to perform tasks autonomously, without intervention of a caller.

An activity is a (typically longer running) method that executes within its own task. Activities can be started automatically (upon object construction) or manually at a later time. Activities can also be stopped at any time. However, to make stopping an activity work, the method implementing the activity has to check periodically whether it has been requested to stop, and if so, return. Activities are stopped before the object they belong to is destroyed. Methods implementing activities cannot have arguments or return values.

Activity objects are used as follows:

class ActiveObject
{
public:
    ActiveObject(): 
        _activity(this, &ActiveObject::runActivity)
    {
        ...
    }

    ...

protected:
    void runActivity()
    {
        while (!_activity.isStopped())
        {
            ...
        }
    }

private:
    Activity<ActiveObject> _activity;
};

Inheritance

Direct Base Classes: Runnable

All Base Classes: Runnable

Member Summary

Member Functions: isRunning, isStopped, run, start, stop, wait

Inherited Functions: run

Types

Callback

typedef typename RunnableAdapterType::Callback Callback;

RunnableAdapterType

typedef RunnableAdapter < C > RunnableAdapterType;

Constructors

Activity inline

Activity(
    C * pOwner,
    Callback method
);

Creates the activity. Call start() to start it.

Destructor

~Activity virtual inline

~Activity();

Stops and destroys the activity.

Member Functions

isRunning inline

bool isRunning() const;

Returns true if the activity is running.

isStopped inline

bool isStopped() const;

Returns true if the activity has been requested to stop.

start inline

void start();

Starts the activity by acquiring a thread for it from the default thread pool.

start inline

void start(
    ThreadPool & pool
);

stop inline

void stop();

Requests to stop the activity.

wait inline

void wait();

Waits for the activity to complete.

wait inline

void wait(
    long milliseconds
);

Waits the given interval for the activity to complete. An TimeoutException is thrown if the activity does not complete within the given interval.

run protected virtual inline

void run();

Securely control IoT edge devices from anywhere   Connect a Device