7

我开始爱上 lambda，不久前我写了一个简单的包装器，它接受一个 lambda 并在一个新线程上启动它。

//
// Starts a task on a separate thread, when passed a lambda expression
//
template<typename T>
smart_ptrs::w32handle StartTask(T f)
{
    // Make a copy of the task on the heap
    T* pTask = new T(f);

    // Create a new thread to service the task
    smart_ptrs::w32handle hThread(::CreateThread(
        NULL, 
        0, 
        (LPTHREAD_START_ROUTINE)& detail::start_task_proc<T>, 
        (LPVOID) pTask, 
        NULL, 
        NULL)); 

    // If the caller ignores this rc, the thread handle will simply close and the
    // thread will continue in fire-and-forget fashion.
    return hThread;
}

注意：是的，我知道这并不需要模板并且可以愉快地使用std::function. 我以这种方式发布它是因为它匹配我拥有的更复杂的（异步队列）版本，这些版本必须是模板。

最终结果是一个非常容易在并行算法等中使用的函数。但是，如果您开始广泛使用这样的函数，就会出现问题。因为创建的线程似乎都来自同一个相当通用的函数，所以很难判断它们是在代码中的什么位置开始的。通常可以从他们正在做的事情的上下文中解决问题，但它不像以前使用显式线程函数那样容易。有没有人有一个很好的方法来标记这些线程，以便它们更容易调试？

4

1 回答 1

3

据我从代码中可以看出，您将拥有start_task_proc在其调用堆栈中的某个位置调用其函数对象的线程。您可以修改该函数以获取指向“任务信息”结构的指针，而不是裸函数对象。您可以将您喜欢的任何信息填充到该信息对象中，例如您创建任务的行号和文件名：

template <class T>
struct TaksInfo {
  T func;
  unsigned line;
  char const* file;

  TaskInfo(T&& t, unsigned l, char const* f)
    : func(std::move(t), line(l), file(f) {}
};


template<typename T>
smart_ptrs::w32handle StartTask(T f, unsigned line, char const* file)
{
    // Make a copy of the task on the heap
    auto pTask = new TaskInfo<T>(f, line, file);

    // Create a new thread to service the task
    smart_ptrs::w32handle hThread(::CreateThread(
        NULL, 
        0, 
        (LPTHREAD_START_ROUTINE)& detail::start_task_proc<T>, 
        (LPVOID) pTask, 
        NULL, 
        NULL)); 

    // If the caller ignores this rc, the thread handle will simply close and the
    // thread will continue in fire-and-forget fashion.
    return hThread;
}

#define START_TASK(f) StartTask(f, __LINE__, __FILE__)

template <class T>
DWORD start_task_proc(LPVOID lpParameter) {
  auto pTask = (TaskInfo<T>*) lpParameter;
  return pTask->func();
}


//use:
int main() {
  auto threadHandle = START_TASK(([]() -> DWORD { std::cout << "foo\n"; return 42;} ));
}

如果您现在检查pTask，start_task_proc您可以看到file并且line可以告诉您任务从哪里开始。
当然，您可以避免TaskInfo结构并使信息只是以下模板参数start_task_proc：

template <class T, unsigned Line, char const* File>
DWORD start_task_proc(LPVOID lpParameter) { /* as you have it */)

template<unsigned Line, char const* File, typename T> //use T last fur type deduction
smart_ptrs::w32handle StartTask(T f)
{
    // Make a copy of the task on the heap
    auto pTask = new T(std::move(f));

    // Create a new thread to service the task
    smart_ptrs::w32handle hThread(::CreateThread(
        NULL, 
        0, 
        (LPTHREAD_START_ROUTINE)& detail::start_task_proc<T, Line, File>,   //!!!
        (LPVOID) pTask, 
        NULL, 
        NULL)); 

    // If the caller ignores this rc, the thread handle will simply close and the
    // thread will continue in fire-and-forget fashion.
    return hThread;
}

#define START_TASK(f) StartTask<__LINE__, __FILE__>(f)
于 2013-06-03T10:41:12.047 回答