52.多线程查找数据

• 设置线程信息结构体

  struct threadInfo
  {
      int *pstart;
      int length;
      int key;
      int id;
  };

• 设置数组

  int a[100];
      time_t ts;
      srand((unsigned int)time(&ts));
      for (int i = 0; i < 100; i++)
      {
          a[i] = rand() % 10;
      }

• 初始化线程结构体并开始线程

         struct threadInfo info[10];
       for (int i = 0; i < 10; i++)
      {
          info[i].pstart = a + i * 10;
          info[i].length = 10;
          info[i].key = 5;
          info[i].id = i;
          _beginthread(find, 0, &info[i]);
      } 

• 多线程函数

  void find(void *p)
  {
      struct threadInfo *pinfo = p;//接受参数
      printf("线程%d开始
  ", pinfo->id);
      for (int *px = pinfo->pstart; px < pinfo->pstart + pinfo->length; px++)
      {
          if (*px == pinfo->key)
          {
              printf("线程%d找到%d,%d
  ", pinfo->id, px, *px);
              enQ(&my1, *px);//地址入队
          }
      }
      printf("线程%d结束
  ", pinfo->id);
  }

  对传入的结构体进行多线程操作.

完整代码:

#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include <process.h>
#include <windows.h>
#include "queue.h"

myQ my1;//队列保存多线程的结果

struct threadInfo
{
    int *pstart;
    int length;
    int key;
    int id;
};

void find(void *p)
{
    struct threadInfo *pinfo = p;//接受参数
    printf("线程%d开始
", pinfo->id);
    for (int *px = pinfo->pstart; px < pinfo->pstart + pinfo->length; px++)
    {
        if (*px == pinfo->key)
        {
            printf("线程%d找到%d,%d
", pinfo->id, px, *px);
            enQ(&my1, *px);//地址入队
        }
    }
    printf("线程%d结束
", pinfo->id);
}

void main()
{
    init(&my1);//初始化队列
    int a[100];
    time_t ts;
    srand((unsigned int)time(&ts));
    for (int i = 0; i < 100; i++)
    {
        a[i] = rand() % 10;
    }
    
    
    struct threadInfo info[10];
    for (int i = 0; i < 10; i++)
    {
        info[i].pstart = a + i * 10;
        info[i].length = 10;
        info[i].key = 5;
        info[i].id = i;
        _beginthread(find, 0, &info[i]);
    }
    Sleep(3000);
    //弹出队列所有数据
    while (!isempty(&my1))
    {
        printf("出队的数据:%d
", getlast(&my1));
        deQ(&my1);
        print(&my1);
    }

    system("pause");
}