windows 和 linux 多线程

　　学习了几天多线程技术，做个总结，便于记忆。

　　一般多线程传递参数为 void* 所以会有一个强制转换过程 (int*) (void *)等，传递多个参数选择结构体指针。为了避免多个线程访问数据冲突会有一个叫做 “临界区”CRITICALSECTION“ 类，防止读写数据冲突，

大概流程是：

CRITICAL_SECTION cs;

init CS(cs);

the one process

enter CS

.....

leaveCS

DELETE(cs);

在利用多线程时候，会遇到数据分割的问题一般的规定是：

假设 data = N process_num = M;

N 能整除M 简单 N/M

N 不能整除 M 则 M-1 个进程的数据处理数为 N/(M-1) 最后一个进程处理数为N - (N/(M-1)*(M-1))

一般利用全局变量完成线程间的简单通信。当然也有timer定时器控制线程启动，和event事件触发线程。

WINDOWS下多线程头文件为 process.h

LINUX下。。。 pthread.h 另外编译时候加上 -lpthread

WINDOWS 新建一个线程有 CreateThread _beginthread (略过参数)

LINUX下。。。 pthread_create

WINDOWS 冻结解冻线程为 SuspendThread() ResumeThread()

LINUX下。。。一般用线程锁 pthread_mutex_lock pthread_mutex_unlock

/*程序流程为：主线程创建子线程（当前子线程状态为stop停止状态），5秒后主线程唤醒子线程，10秒后主线程挂起子线程，15秒后主线程再次唤醒子线程，20秒后主线程执行完毕等待子线程退出。

代码如下：*/
#include "stdio.h"
#include "unistd.h"
#include "pthread.h"
#include "string.h"
#include "time.h"

#define RUN 1
#define STOP 0

pthread_mutex_t mut = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

int status = STOP;
void * thread_function(void)
{
    static int i = 0;
    while (1) 
    {   
        pthread_mutex_lock(&mut);
        while (!status)
        {
            pthread_cond_wait(&cond, &mut);
        }
        pthread_mutex_unlock(&mut);

        printf("child pthread %d\n", i++);
        if (i == 20) 
            break;
        sleep(1);
    }   
}

void thread_resume()
{
    if (status == STOP)
    {   
        pthread_mutex_lock(&mut);
        status = RUN;
        pthread_cond_signal(&cond);
        printf("pthread run!\n");
        pthread_mutex_unlock(&mut);
    }   
    else
    {   
        printf("pthread run already\n");
    }   
}

void thread_pause()
{
    if (status == RUN)
    {   
        pthread_mutex_lock(&mut);
        status = STOP;
        printf("thread stop!\n");
        pthread_mutex_unlock(&mut);
    }   
    else
    {   
        printf("pthread pause already\n");
    }
}

int main()
{
    int err;
    static int i = 0;
    pthread_t child_thread;

#if 0
    if (pthread_mutex_init(&mut, NULL) != 0)
        printf("mutex init error\n");
    if (pthread_cond_init(&cond, NULL) != 0)
        printf("cond init error\n");
#endif

    err = pthread_create(&child_thread, NULL, (void *)thread_function, NULL);
    if (err != 0 )
        printf("can't create thread: %s\n", strerror(err));
    while(1)
    {
        printf("father pthread %d\n", i++);
        sleep(1);
        if (i == 5)
            thread_resume();
        if (i == 10)
            thread_pause();
        if (i == 15)
            thread_resume();
        if (i == 20)
            break;
    }
    if (0 == pthread_join(child_thread, NULL))
        printf("child thread is over\n");
    return 0;
}

。。。。。涉及到线程间的同步与异步一般会用到如下函数。。。。。。。。。。。。

windows 等待线程结束 WaitForSingleObject() WaitForMultipleObjects()

Linux 。。。 pthread_join()

windows 退出线程 ExitThread() TerminateThread()/强制结束线程

linux 退出线程 pthread_exit()

还有关键的 SIGNAL 没有学习，再UPDATE吧。

最后附上linux 和windows 多线程测试代码

linux : gcc test.c -fopenmp -lpthread -o test

#include "stdio.h"
#include "omp.h"
#include "time.h"
#include "unistd.h"
#include "pthread.h"

clock_t start,end;

void* test(void *p){

start = clock();
int i;
for(i=0;i<100000;i++)
usleep(1);

end = clock();

printf("process test    %d\n",end-start);
return ((void *)0);
}


void* test1(void *P){
start = clock();
int i;
#pragma omp parallel for
for(i = 0;i<100000;i++)
usleep(1);

end = clock();
printf("process test1   %d\n",end-start);
return ((void *)0);

}
int main(){

int err;

pthread_t ntid;
pthread_t ntid1;
void** out;


err = pthread_create(&ntid,0,test,0);

if(err !=0) putchar('N');
err =pthread_create(&ntid1,0,test1,0);

if(err !=0) putchar('N');
//test(0);
//test1(0);

printf("Main process\n");
pthread_join(ntid,out);
pthread_join(ntid1,out);


return 0;

}

windows :

#include <windows.h>
#include <iostream>
#include <process.h>
#include <time.h>

#define _CRT_SECURE_NO_WARNINGS
using namespace std;

CRITICAL_SECTION cs;

int i = 0;

void run(void *){

char num[30];
while (1){
sprintf(num,"title %d",i++);
system(num);
Sleep(1000);
//MessageBox(0,(LPCTSTR)num,(LPCTSTR) num, 0);
}

}



int main(){


int hd[4];
MessageBoxA(0, "1", "1", 0);
//for (int i = 0; i < 4; i++){
hd[i] = _beginthread(run, 0, 0);
//}
WaitForSingleObject(hd, true);
system("pause");
return 0;
}

参考文献：

http://www.cnblogs.com/gnuhpc/archive/2012/12/07/2807484.html

http://blog.csdn.net/zhouruifu2015/article/details/47833985

http://blog.chinaunix.net/uid-29145190-id-4341878.html

http://edu.51cto.com/lesson/id-86087.html

秒客网

windows 和 linux 多线程

相关文章