zoukankan      html  css  js  c++  java
  • Simple Worker Thread Class

    http://www.codeproject.com/Articles/36184/Simple-Worker-Thread-Class

    Introduction

    Many times we need to create worker threads and generally we want to wait in the main thread till all worker threads finish their execution, something similar to pthread’s pthread_join call. We want some notification on the completion of worker thread; check the status of the worker thread if it is still executing in thread function or finished, etc. Also sometimes we want to keep the worker thread alive even on completion of thread function so that we can resubmit a different job (typically in a thread pool). All these things can be done with event objects by managing their state to signalled non signaled, etc. It is difficult to manage such code using different event objects. I consolidated all this commonly used worker thread functionality in a basic implementation of WorkerThread class.

    WorkerThread Class

    WorkerThread is a basic implementation for worker thread with PostThreadMessageJoin,RegisterOnCompleteRoutine and thread execution status. It can be enhanced further for many other features but I want to keep the idea simple. Here my main focus is just to show how to use a PostThreadMessage for worker threads.

    Using the Code

    Using WorkerThread class in your existing application is very simple. You just need to add WorkerThread.cpp in your project and include WorkerThread.h where you want to use this class.

    Add variables of WorkerThread class wherever you want to create a worker thread. Create a worker thread usingStart() with an optional auto quit parameter (default is true) and to end the thread, use End() method. If auto quit parameter is true, there is no need to call End() method of WorkerThread class. Join() method will simply cause calling thread to wait till work thread finishes its execution. GetStatus() will let you know the current thread status (NotCreatedCreatedStartedRestartedComplete). ReExecute() method can be used only for non auto quit threads (created with false parameter in constructor) with different or same data (this can be further enhanced to avoid overwriting the data). RegisterOnCompleteRoutine() method can be used to register an optional routine that will be called on completion of thread function.

    Below is the sample code to show the usage of the WorkerThread class:

    #include "stdafx.h"
    #include "WorkerThread.h"
    
    #define MAXCOUNT 5
    
    DWORD WINAPI ThreadProc(void *param)
    {
        int i = (int)param;
        //
        // your code
        //
        
        return 0;
    }
    
    DWORD WINAPI OnComplete(void *param)
    {
        int i = (int)param;
    
        printf("OnComplete data = %d
    ", i);
    
        return 0;
    }
    
    int _tmain(int argc, _TCHAR* argv[])
    {
        // Create few worker threads with autoQuit false
        WorkerThread workerThread[MAXCOUNT] = {false, false, false, false, false};
    
        // Register an optional completion routine
        workerThread[2].RegisterOnCompleteRoutine(OnComplete, (void *)1234);
    
        // Start all of them
        for (int i = 0; i < MAXCOUNT; ++i) {
            if (workerThread[i].Start(ThreadProc, (void *)i)) {
                printf("Started %d
    ", i);
            }
        }
    
        for (int i = 0; i < MAXCOUNT; ++i) {
            if (workerThread[i].ReExecute((void *)i)) {
                printf("Restarted %d
    ", i);
            }
    
        }
    
        for (int i = 0; i < MAXCOUNT; ++i) {
            workerThread[i].End();
        }
    
        // main thread will wait here, till all others finish.
        for (int i = 0; i < MAXCOUNT; ++i) {
            workerThread[i].Join();
        }
    
        return 0;
    }        
  • 相关阅读:
    Django自带的用户认证auth模块
    Django logging模块
    python之MRO和垃圾回收机制
    Django内置form表单和ajax制作注册页面
    自定义登录验证的中间件
    中间件控制访问评率
    多表查询
    单表查询
    同一服务器部署多个tomcat时的端口号修改详情
    反射获取类中的属性和set属性
  • 原文地址:https://www.cnblogs.com/shangdawei/p/4003903.html
Copyright © 2011-2022 走看看