Thread Watcher

Thread watcher is a C++ based implementation to monitor running threads by executions states.

Build	Status
Windows
Linux

Process states

Eache processing thread starts by an Init state if only created but not started from thread watcher. If thread watcher is running all process will be automatic executed and has the running state. By stopping an process it trys to Stop this thread clean (finished) and if it's not work hard killed (killed). If both methods to kill not work an killed exception status will be set to process.

Build

This project can be build with cmake for all platforms. All dependencies will be downloaded from hunter repository. Currently the source code part to kill processes hard is not platform independent and use the Windows API.

Build with ccmake

ccmake .

Build with cmake

cd build
cmake ..

Example

This example codes shows a simple usage from thread watcher.

First of all code an process class which implements the IFunction interface.

class CleanProcess : public ::IFunction
{

public:

    CleanProcess()
    {
        stopProcess = false;
    }

    virtual ~CleanProcess() {};

    /**
     * Overridden function.
     */
    void process() override
    {
        while (!stopProcess) 
        {
             // Implement here your processing code
        }
    }

    /**
     * Overridden function.
     */
    void Stop() override
    {
        stopProcess = true;
    }

private:

    /**
     * @brief Atomic boolean to Stop process.
     */
    std::atomic<bool> stopProcess;
};

Use this processing in an thread watcher to monitor his running states and Start watcher to Watch all added processes.

ThreadWatcher watcher;
std::shared_ptr<IFunction> ptrProcess(new CleanProcess());
std::shared_ptr<Process> processClean(new Process(ptrProcess));
watcher.AddProcess("PROCESS_A39", processClean);
// Added process will be in state init if watcher not started.
watcher.HasProcessStatus("PROCESS_A39", Process::Status::INIT)

// Important this call will block the execution by thread.join() method from watcher.
watcher.Watch();

// If watcher is started process should be in state run.
watcher.HasProcessStatus("PROCESS_A39", Process::Status::RUN)

License

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Nepitwin/ThreadWatcher

Thread Watcher

Process states

Build

Example

License