#include <stdio.h> #include <pthread.h> #include <stdlib.h> #include <string.h>/* 聲明變量 */ int array_length, file_length; int *array_master; FILE *freader;/* 用于從文件讀取數(shù)據(jù) */ int *read_file(char *fname) {freader = fopen(fname, "rt"); /* 只讀方式打開文件 */int bufsize = file_length; /* 數(shù)組規(guī)模 */char line[80];int integer;int index = 0;int *input = (int *)malloc(bufsize*sizeof(int)); /* 動(dòng)態(tài)分配內(nèi)存空間 */while (fgets(line, 80, freader) != NULL){sscanf(line, "%d", &integer); /*從字符串 line 中獲得整數(shù)（完成字符串到整數(shù)的轉(zhuǎn)換）*/input[index] = integer;++index;++array_length;}fclose(freader); /* 關(guān)閉文件 */return input; }/* 求文件的行數(shù)（也就是數(shù)據(jù)量）*/ int read_length(char *fname) {freader = fopen(fname, "rt"); /* 以只讀方式打開文件 */char line[80];int file_length = 0;/* fgets 從數(shù)據(jù)文件中讀數(shù)據(jù)，每讀一行的字符串（最長(zhǎng)為80個(gè)字符），讀到文件末尾 EOF，返回NULL */while (fgets(line, 80, freader) != NULL)file_length += 1;return file_length; }/* 歸并函數(shù) */ void merge(int arr[], int left, int middle, int right) {int i, j, k;int half1 = middle - left + 1; /* 數(shù)組前一半的數(shù)據(jù)量 */int half2 = right - middle; /* 數(shù)組后一半的數(shù)據(jù)量 */int first[half1], second[half2]; /* 聲明兩個(gè)臨時(shí)數(shù)組，保存前半部分?jǐn)?shù)據(jù)和后半部分?jǐn)?shù)據(jù) *//* 從 arr 數(shù)組復(fù)制 left 到 right 之間前半部分的數(shù)據(jù) */for (i = 0; i < half1; i++) first[i] = arr[left + i]; /* 從 arr 數(shù)組復(fù)制 left 到 right 之間后半部分的數(shù)據(jù) */for (j = 0; j < half2; j++) second[j] = arr[middle + 1 + j];i = 0;j = 0;k = left;/* 比較兩個(gè)臨時(shí)數(shù)組的數(shù)，找出當(dāng)前最小的數(shù)，然后按序存入 arr */while (i < half1 && j < half2) {if (first[i] <= second[j]) {arr[k] = first[i];++i; }else {arr[k] = second[j];j++;}k++; /* arr 數(shù)組的索引 */}/* 將臨時(shí)數(shù)組中剩余的數(shù)存入 arr 數(shù)組 */while (i < half1) {arr[k] = first[i];i++;k++;}while (j < half2){arr[k] = second[j];j++;k++;} }/* 歸并排序函數(shù) */ void* merge_sort(void* arg) {/* 變量聲明 */int *arr = array_master; /* 指向全局變量 array_master 數(shù)組 */int *argu = (int*)arg;int l = argu[0]; /* 由線程傳入的參數(shù)，獲得要排序數(shù)據(jù)的最小索引值 */int r = argu[1]; /* 由線程傳入的參數(shù)，獲得要排序數(shù)據(jù)的最大索引值 *//* 若 l==r 則不必排序 */if (l < r) { /* 聲明兩個(gè)線程買描述符 */pthread_t tid1;pthread_t tid2;/* 聲明調(diào)用線程處理函數(shù)的參數(shù) */int arg1[2];int arg2[2];int middle;middle = (l + (r - 1)) / 2;arg1[0] = l;arg1[1] = middle;arg2[0] = middle + 1;arg2[1] = r;/* 由于用二分法對(duì)數(shù)組分成兩部分分別排序，所以存在并行的可能，這里采用多線程 */pthread_create(&tid1, NULL, merge_sort, arg1);pthread_create(&tid2, NULL, merge_sort, arg2);/* 這里必須等待兩部分?jǐn)?shù)組都已排序完畢，才能進(jìn)行歸并，所以這里調(diào)用 pthread_join 使得線程同步 */pthread_join(tid1, NULL);pthread_join(tid2, NULL);/* 此時(shí)歸并兩個(gè)已排序子序列 */merge(arr, l, middle, r);pthread_exit(0);}return NULL; }/* 主函數(shù) */ int main(int argc, char *argv[]) {char *fname = argv[1]; /* 從命令行中讀取數(shù)據(jù)文件 *//* 獲取數(shù)據(jù)的長(zhǎng)度 */file_length = read_length(fname);/* 從數(shù)據(jù)文件中讀取數(shù)據(jù) */array_master = read_file(fname);int arg[2];arg[0] = 0;arg[1] = file_length - 1;/* 創(chuàng)建線程執(zhí)行歸并排序 */pthread_t tid;pthread_create(&tid, NULL, merge_sort, arg);/* 進(jìn)程同步 */pthread_join(tid, NULL);/* 打印已排序數(shù)組 */int j;for (j = 0; j < array_length; j++) {if (j == array_length - 1) printf("%d\n", array_master[j]); /* 打印已排序數(shù)組的最后一個(gè)元素 */else printf("%d, ", array_master[j]); /* 打印已排序數(shù)組的非最后一個(gè)元素 */}return 0; }

?

轉(zhuǎn)載于:https://www.cnblogs.com/wanghao-boke/p/11608164.html

總結(jié)

以上是生活随笔為你收集整理的C语言实现多线程排序的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。