4

我正在编写一个赋值程序，它使用线程实现两个给定数组之间的矩阵乘法。

我必须给出我想用作命令行参数的线程数，如果它们的数量小于第一个数组的行数，则重复使用一些相同的线程，直到整个工作完成。

我设法让它工作，但只为数组的每一行使用一个线程。例如，如果 a 有 5x5 乘法并且使用少于 5 个线程，我会出现分段错误，这是有道理的。

我的问题是：该线程完成工作后如何重用线程？在前面的示例中，我的意思是如果我想为 5x5 使用 2 个线程，我的程序应该像这样工作：

线程 1-> 第 1 行

线程 2->第 2 行

线程 2-> 第 3 行

线程 1-> 第 4 行

等等

4

1 回答 1

3

您有多种可能性，但主要思想是您必须监视线程以检测它们何时完成工作，并且有办法知道是否还有一些事情要做。

想到的第一个方法是有一个专用线程来跟踪所有正在运行的线程，并在它们完成后回收它们。但是为了做到这一点，您需要一种让线程同步的机制，这可以使用信号量或互斥锁或消息来实现，但如果您不需要它，仅为此目的编写代码可能会很麻烦.

第二种方法是简单地要求他们回收自己，因为他们知道何时完成。在许多其他语言中，有一种称为延续的机制，它可以让你完全做到这一点，但由于我们正在处理 C，我们需要手动完成。幸运的是，这里的延续实际上只是一个单一的任务。

所以调用continuation的机制其实只是一个函数，它会先运行要被线程执行的任务，然后要么：

  • 检查任务列表。此任务列表必须在设置时填写任务需要完成的所有工作，
  • 将线程添加到可用线程队列中，必须由其他线程再次检查并重新分配新任务，

显然，第一个选项会更容易，并且在您的情况下，您在设置时已经知道必须做什么，因此您的设置功能可以填写任务列表，然后启动任意数量的线程，并让它们自己做回收。

这是一个你可以开始的简单骨架：

 typedef struct {
    /* task related data */
 } task_t;

 // basic list structure
 typedef struct {
   list_t *next;
   void *data; // here app specific data
 } list_t;

 list_t task_list; // your task list

 // a few operators to manipulate a list
 // implementation must use a mutex to avoid race conditions
 void list_push(list *l, void *data);
 void *list_pop(list *l);


 // thread function

 void do_task(task_t *task){
     while (task) {
       run_task(task); // that would be the matrix related function
       task = list_pop(&task_list);
 }

 // here a simple define for the number of threads
 // you might want to check the number of available cores instead

 #define MAX_THREAD_COUNT 4 

 int main() {

   pthread_t threads[MAX_THREAD_COUNT];

   setup_task_list();  // push all the work that must be done in the list
   int i;
   for (i = 0; i < MAX_THREAD_COUNT; i++) {
      pthread_create(threads + i, NULL, do_task, list_pop(&task_list));
   }

   // here wait for all the threads, or detach them

 }

这是您可以做什么的基本大纲，应该可以帮助您入门。关于 SO 处理 C 链表有几个问题。这里的那个必须是同步的，不应该阻塞，NULL空的时候返回。

于 2012-11-14T08:51:16.117 回答