C++에서 pthread를 사용하는 매우 큰 배열의 최대 요소

문제 설명

매우 큰 정수 배열이 주어지면 멀티스레딩을 사용하여 배열 내에서 최대값 찾기

예시

입력 배열이 {10, 14, -10, 8, 25, 46, 85, 1673, 63, 65, 93, 101, 125, 50, 73, 548}이면

이 배열의 최대 요소는 1673입니다.

알고리즘

• 배열 크기를 total_elements라고 합시다
• N개의 스레드 생성
• 각 스레드는 (total_elementes/N) 배열 요소를 처리하고 여기에서 최대 요소를 찾습니다.
• 마지막으로 각 스레드에서 보고한 최대값에서 최대값을 계산합니다.

예시

#include <stdio.h>
#include <pthread.h>
#include <stdlib.h>
#include <limits.h>
#define MAX 10
#define SIZE(arr) (sizeof(arr) / sizeof(arr[0])) typedef struct struct_max {
   int start;
   int end;
   int thread_num;
} struct_max;
int arr[] = {10, 14, -10, 8, 25, 46, 85, 1673, 63, 65, 93, 101, 125, 50, 73, 548};
int max_values_from_threds[MAX];
void *thread_fun(void *arg) {
   struct_max *s_max = (struct_max*)arg;
   int start = s_max->start;
   int end = s_max->end;
   int thread_num = s_max->thread_num;
   int cur_max_value = INT_MIN;
   for (int i = start; i < end; ++i) {
      if (arr[i] > cur_max_value) {
         cur_max_value = arr[i];
      }
   }
   max_values_from_threds[thread_num] = cur_max_value;
   return NULL;
}
int main() {
   int total_elements = SIZE(arr);
   int n_threads = 4;
   struct_max thread_arr[4];
   for (int i = 0; i < 4; ++i) {
      thread_arr[i].thread_num = i + 1;
      thread_arr[i].start = i * 4;
      thread_arr[i].end = thread_arr[i].start + 4;
   }
   pthread_t threads[4];
   for (int i = 0; i < 4; ++i) {
      pthread_create(&threads[i], NULL, thread_fun, &thread_arr[i]);
   }
   for (int i = 0; i < 4; ++i) {
      pthread_join(threads[i], NULL);
   }
   int final_max_val = max_values_from_threds[0];
   for (int i = 0; i < n_threads; ++i) {
      if (max_values_from_threds[i] > final_max_val) {
         final_max_val = max_values_from_threds[i];
      }
   }
   printf("Maximum value = %d\n", final_max_val);
   return 0;
}

출력

위의 프로그램을 컴파일하고 실행할 때. 다음 출력을 생성합니다 -

Maximum value = 1673