Linux多线程编程

程序代码test.c共两个线程，一个主线程，一个读缓存区的线程：

#include <pthread.h>

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <unistd.h>

char globe_buffer[100]

void *read_buffer_thread(void *arg) //这里先声明一下读缓存的线程，具体实现写在后面了

int main()

{

int res,i

pthread_t read_thread

for(i=0i<20i++)

globe_buffer[i]=i

printf("\nTest thread : write buffer finish\n")

sleep(3)\\这里的3秒是多余，可以不要。

res = pthread_create(&read_thread, NULL, read_buffer_thread, NULL)

if (res != 0)

{

printf("Read Thread creat Error!")

exit(0)

}

sleep(1)

printf("waiting for read thread to finish...\n")

res = pthread_join(read_thread, NULL)

if (res != 0)

{

printf("read thread join failed!\n")

exit(0)

}

printf("read thread test OK, have fun!! exit ByeBye\n")

return 0

}

void *read_buffer_thread(void *arg)

{

int i,x

printf("Read buffer thread read data : \n")

for(i=0i<20i++)

{

x=globe_buffer[i]

printf("%d ",x)

globe_buffer[i]=0//清空

}

printf("\nread over\n")

}

---------------------------------------------------------------------------------

以上程序编译：

gcc -D_REENTRANT test.c -o test.o –lpthread

运行这个程序：

$ ./test.o：

LinuxC++编写线程安全库dll的方法：

1、动态库只有一个导出函数。

这种情况下编写函数时，只需要考虑不要有冲突的全局数据就可以了。这里的全局数据包括了在堆中分配的数据块和静态全局变量等。如果存在这样的全局数据，那么进程中的不同线程访问这个函数就会造成冲突。

2、动态库导出了多个函数，而且多个函数间存在数据传递。

一般DLL都导出多个函数，一个初始化，一个资源释放，其他为核心功能函数。这些函数间极有可能发生数据传递。如果一个初始化函数是在线程A中调用的，而核心功能函数是在线程B中调用的，那么线程A初始化函数的资源就无法对应线程B中的核心功能，此外还有核心功能函数间的数据传递，这样的DLL就不是线程安全的，必然导致错误。

解决办法是由用户（即使用DLL的人）保证这些导出函数是在一个线程中调用。但这样会很大程度上限制接口的设计和用户的使用自由度。所以最好的方法是函数只管自己的线程安全，不同函数传递数据用动态TLS，线程局部存储。

3、限制访问DLL中某一函数的线程数目。

对于DLL中的某一个函数的访问线程数目是有限制的，超过了限制其他线程就得等一定的时间，一定的时间过后如果还不能得到执行机会，那就返回超时。这样的设计对用户来说是友好的，而且很实用，有的商业程序确实是按照允许用户访问的通道数目来计价的。

对DLL中的函数做这样的一个封装，一般是简单的待用Semaphore信号量，来解决。DLL初始化时调用CreateSemaphore函数对信号量进行初始化，其原型如下：

HANDLE CreateSemaphore(

LPSECURITY_ATTRIBUTES lpSemaphoreAttributes,

// pointer to security attributes

LONG lInitialCount, // initial count

LONG lMaximumCount, // maximum count

LPCTSTR lpName // pointer to semaphore-object name

)

对于信号量，它每WaitForSingleObject一次（当然是要进入），其状态值（一个整数）就减1，使用完ReleaseSemaphore其状态值就加1，当其状态值为0时信号量就由有信号变为无信号。利用信号量的这一特性，我们在初始化时将信号量的初始值（第2个参数）设置为限制的线程访问数目。在要限制访问线程数目的函数内部，通过调用WaitForSingleOject获取控制权，并指定一个等待时间（这个由配置文件指定），根据情况超时返回，使用完ReleaseSemaphore释放对占用，让其他线程可以调用这个函数。

4、多进程情况下的多线程安全DLL。

LL是可以被多个进行加载并调用的。那就是说如果我们只对一个进程进行了限制，那么在多进程调用的情况下，这样的限制被轻易攻破。

我们都知道，Semaphore信号量属于内核对象，也就是说其可以被多进程共享访问，也就说，如果我们给一个Semaphore指定了一个名字，在另一个进程中，我们只要调用OpenSemaphore函数用同一名字打开信号量就可以访问了。这样问题就解决了？

现实情况是，多进程情况下，一般不是简单的多进程共享一个Semaphore就可以了。多进程间需要互通很多信息。一般的解决办法是，采用共享数据段。

#pragma data_seg("share")

int share_data

#pragma data_seg()

#pragma comment(linker,"/SECTION:share, RWS")

通过pragam编译器指令生成了一个名叫share的共享数据段，这样对于变量share_data就可以多进程共享的了。如果要多进程间交换数据，只要在data_seg中添加数据定义即可。

给你举个例子：

比方电脑里你安装的qq，暴风，迅雷他们都可以单独独立运行，那么我们就可以说qq是一个进程，暴风也是一个进程，迅雷更是一个进程

而要说到什么是线程，线程是运行在进程里里的程序

举例qq（线程），我们能同时用qq软件进行聊天，听音乐，为什么呢，这就是线程的优点所在，单独运行但又不互相干扰，创建线程有两种方法，线程一定要复写run方法，用start启动线程

使用Thread创建线程：

public MyThread extends Thread{

public void run(){

for (int i=0i<20i++){

System.out.println(

“my Thread i value: ”+i)

}

使用Runnable创建线程：

public MyThread implements Runnable{

public void run(){

for (int i=0i<20i++){

System.out.println(

“my Thread i value: ”+i)

}

对于这两种方法，实现线程，但是一般情况下我们都用第二种

因为第一种是用继承的关系，而第二种为实现接口

但是相对于第一种，第二种我们还可以另外继承类，来扩展功能，所以编程序时比较趋向于用实现的方法写线程

给你一个完整的例子：

class MyThread implements Runnable{

private int ticket = 5 // 假设一共有5张票

public void run(){

for(int i=0i<100i++){

if(ticket>0){ // 还有票

System.out.println(Thread.currentThread().getName()+"卖票：ticket = " + ticket-- )

}

}

}

}

public class SyncDemo01{

public static void main(String args[]){

MyThread mt = new MyThread() // 定义线程对象

Thread t1 = new Thread(mt) // 定义Thread对象

Thread t2 = new Thread(mt) // 定义Thread对象

Thread t3 = new Thread(mt) // 定义Thread对象

t1.start()

t2.start()

t3.start()

}

}

这是一个三线程：

三个线程都start，所以他们可以同时运行，但是又由于电脑cpu只有一个，只能运行一个线程，那么这三个线程就会去抢，谁抢到谁就线运行，start表示开始运行run方法，导致三个线程共享5个车票，你会发现每次运行结果不一样，这就是抢的结果，如果把车票写在run方法里就不一样了

Thread-0卖票：ticket = 5

Thread-0卖票：ticket = 4

Thread-0卖票：ticket = 3

Thread-2卖票：ticket = 2

Thread-2卖票：ticket = 1

结果二：

Thread-0卖票：ticket = 5

Thread-0卖票：ticket = 4

Thread-0卖票：ticket = 3

Thread-1卖票：ticket = 2

Thread-0卖票：ticket = 1

反正很多答案，自己试。

---