一个简单的求数组最大值的程序，为什么我的多线程比串行要慢？？？各位大神速来，跪求

我叫桃花贼

为什么多线程与串行时间相差无几，真心不明白，我能考虑的地方都已经考虑了
我的PC是4个core i3 M380, cache结构有三级。
各位大哥，代码如下（复制粘贴即可执行），求指导！


#include "stdio.h"
#include <malloc.h>
#include <time.h>
#include <pthread.h>

int *a;//需要求最大值的数组
int length,thread_num,max;//定义数组长度，线程数
pthread_t *threads;//线程数组
pthread_mutex_t lock=PTHREAD_MUTEX_INITIALIZER;//初始化锁

struct padded_int{//为了消除cache之间的假共享线程私有变量thread_max，定义一个结构体，通过添加一个60的字符数组将其填充之一个CACHE行大小，即64
int thread_max;
char padding[60];
} *private_max;


void *Max(void *id){//各线程执行的MAX函数，将一个数组分成thread_num个段，每个线程执行一段
int tid=(int)id;
int length_per_thread=length/thread_num;//每个线程计算的长度
int start=tid*length_per_thread;
int i;

for(i=start;i<start+length_per_thread;i++){

        if(a[i]>private_max[tid].thread_max) private_max[tid].thread_max=a[i];
}

pthread_mutex_lock(&lock);
if(private_max[tid].thread_max>max) max=private_max[tid].thread_max;
pthread_mutex_unlock(&lock);

printf("%d\n",(int)id);
}

int main(int argc ,char **argv){

        int i;
        length=atoi(argv[1]);
        thread_num=atoi(argv[2]);
        clock_t start,end;//计算程序时间
        double duration;
        start =clock();
        private_max=(struct padded_int*)malloc(sizeof(struct padded_int)*(thread_num));
        a=(int*)malloc(sizeof(int)*(length));
        threads=(pthread_t*)malloc((thread_num)*sizeof(int *));
for (i = 1; i <=length; i++)//按最坏情况生成数组a[]，即升序
        {
                a[i] = i;
        }

for(i=0;i<thread_num;i++){
        int ret;
        ret = pthread_create(&threads[i], NULL, Max, (void*)i);
        }

for(i=0;i<thread_num;i++){
                pthread_join(threads[i], NULL);
        }

printf("%d\n",max);
end=clock();
duration =(double) (end- start)/CLOCKS_PER_SEC;
printf("%lf\n",duration);//输出程序运行时间
}

我叫桃花贼

大神们，你们在哪？

我叫桃花贼

在线求解答啊

linux_c_py_php

有锁, 锁和计算相比, 锁不可忽略, 所以是假并行.

我叫桃花贼

回复 4# linux_c_py_php
把锁的那两行代码注释掉，结果也一样啊

   

我叫桃花贼

回复 4# linux_c_py_php
数组长度比较大，设为五千万，结果也一样

   

flyingeagle1015

你这里即便是5千万的数据比较也很快，创建线程的开销不容忽视。

mymtom_cu

回复 6# 我叫桃花贼

启动了几个线程？

zyr-linux

for(i=0;i<thread_num;i++){
        int ret;
        ret = pthread_create(&threads[i], NULL, Max, (void*)i);
        }

for(i=0;i<thread_num;i++){
                pthread_join(threads[i], NULL);
        }


thread_num是多少？
看起来不会小，而且thread里面还有锁……

timespace

像CPU bound的代码
1.线程数量不应多于core的数量
2.用了多线程，调度器也不一定会把线程均匀分布到四个core上，用sched_setaffinity强制指定吧