【问题标题】:How to use Win32 ThreadPool API?如何使用 Win32 线程池 API?
【发布时间】:2017-12-05 15:41:19
【问题描述】:

此版本(基于this 文章)有效:

#include <windows.h>
#include <tchar.h>
#include <stdio.h>

VOID
CALLBACK
MyWorkCallback(
    PTP_CALLBACK_INSTANCE Instance,
    PVOID                 Parameter,
    PTP_WORK              Work
)
{
    // Instance, Parameter, and Work not used in this example.
    UNREFERENCED_PARAMETER(Instance);
    UNREFERENCED_PARAMETER(Parameter);
    UNREFERENCED_PARAMETER(Work);

    DWORD threadId = GetCurrentThreadId();

    BOOL bRet = FALSE;

    //
    // Do something when the work callback is invoked.
    //
    {
        _tprintf(_T("MyWorkCallback: ThreadId = %d Task performed.\n"), threadId);
    }

    return;
}

int main()
{
    TP_CALLBACK_ENVIRON CallBackEnviron;
    PTP_POOL pool = NULL;
    PTP_CLEANUP_GROUP cleanupgroup = NULL;
    PTP_WORK_CALLBACK workcallback = MyWorkCallback;
    PTP_TIMER timer = NULL;
    PTP_WORK work = NULL;


    InitializeThreadpoolEnvironment(&CallBackEnviron);
    pool = CreateThreadpool(NULL);
    SetThreadpoolThreadMaximum(pool, 1);
    SetThreadpoolThreadMinimum(pool, 3);
    cleanupgroup = CreateThreadpoolCleanupGroup();
    SetThreadpoolCallbackPool(&CallBackEnviron, pool);
    SetThreadpoolCallbackCleanupGroup(&CallBackEnviron, cleanupgroup, NULL);
    work = CreateThreadpoolWork(workcallback, NULL, &CallBackEnviron);
    for (int i = 0; i < 10; ++i)
    {
        SubmitThreadpoolWork(work);
    }
}

但是,这个版本也可以工作(与上面的工作函数相同):

int main()
{
    PTP_WORK = CreateThreadpoolWork(workcallback, NULLPTR, NULLPTR);
    for (int i = 0; i < 10; ++i)
    { 
        SubmitThreadpoolWork(work);
    }
}

两个版本有什么区别(除了最小和最大线程数)?
为什么我要使用一个版本而不是另一个版本?

【问题讨论】:

  • 您实际上并未使用清理组支持的功能。并且设置 max = 1 和 min = 3 是没有意义的。所以你更喜欢 2nd sn-p,更简单的需求需要更少的代码。

标签: c++ winapi threadpool


【解决方案1】:

InitializeThreadpoolEnvironment 的文档中对此进行了介绍:

如果您打算调用以下函数之一来修改环境,请创建一个回调环境:

  • SetThreadpoolCallbackCleanupGroup

  • SetThreadpoolCallbackLibrary

  • 设置线程池回调池

  • 设置线程池回调优先级

  • SetThreadpoolCallbackRunsLong

如果您需要一个或多个列出的函数提供的功能,那么您需要创建一个回调环境。如果你不这样做,你就不会。

如果在开始一个新项目时有疑问,请使用简单的方法开始,看看它是否满足您的需求。如果有必要,您可以随时返回并切换到更复杂的变体。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2010-09-19
    • 2011-07-25
    • 2015-03-28
    • 2012-05-09
    • 1970-01-01
    • 2018-10-26
    • 2011-11-23
    • 1970-01-01
    相关资源
    最近更新 更多