现在的位置: 首页 > 综合 > 正文

线程创建后,未必立即运行

2013年10月22日 ⁄ 综合 ⁄ 共 3103字 ⁄ 字号 评论关闭

 

    线程创建,并不立即执行,而是等时间片到来后再执行。

 

     一个进程,包含多个线程。

      则这个线程共享进程的数据等资源,各个线程呈现并发执行状态。

      线程执行时,所传入的参数值是执行时才传入的,而不是创建线程时传入的。

 

 

考虑以下程序:

 

#include "stdafx.h"
#include <iostream>
#include <Windows.h>
#include <process.h>

using namespace std;

long g_nNum;
unsigned int _stdcall ThreadFun(void *pPM);
const int THREAD_NUM=10;
CRITICAL_SECTION g_csThreadCore;
HANDLE hSemaphore;

 

int main(array<System::String ^> ^args)
{
	g_nNum=0;
	HANDLE handle[10];
	int i=0;

	//初始化关键段
	InitializeCriticalSection(&g_csThreadCore);
	//创建信号量
	hSemaphore=CreateSemaphore(NULL,0,1,NULL);


	while(i<THREAD_NUM)
	{
		handle[i]=(HANDLE)_beginthreadex(NULL,0,ThreadFun,&i,0,NULL);
	//	WaitForSingleObject(hSemaphore,INFINITE);
		i++;
	}

	WaitForMultipleObjects(THREAD_NUM,handle,TRUE,INFINITE);

	DeleteCriticalSection(&g_csThreadCore);
	CloseHandle(hSemaphore);
 

	cin>>i;
    return 0;
}


unsigned int _stdcall  ThreadFun(void *pPM)
{

	int nThreadnum=*(int*)pPM;
	ReleaseSemaphore(hSemaphore,1,NULL);
	
	//Sleep(50);
	EnterCriticalSection(&g_csThreadCore);
	g_nNum++;
//	Sleep(50);
	printf("线程编号为%d  全局资源值为%d\n",nThreadnum,g_nNum);

	LeaveCriticalSection(&g_csThreadCore);
	return 0;

}

 

  

运行结果:

 

线程编号为7  全局资源值为1
线程编号为7  全局资源值为2
线程编号为8  全局资源值为3
线程编号为7  全局资源值为4
线程编号为7  全局资源值为5
线程编号为7  全局资源值为6
线程编号为10  全局资源值为7
线程编号为10  全局资源值为8
线程编号为7  全局资源值为9
线程编号为7  全局资源值为10

由此可见,线程编号不正确,原因是:

        创建线程后,不立即执行, 当执行时,传入参数的值已经改变。

        而且,线程编号有重复值, 这说明在i值改变前,启动了好几个线程, 传入这些线程的值都是i(编号),因此才会出现线程编号重复问题。

        比如: i==0时,创建线程0

                      i==1时,创建线程1

                      i==2时,创建线程2

         但,此时还没有一个线程执行,当i=3时,创建线程3,

         此时,时间片轮到线程了,因此可能线程0开始执行,但执行线程0时,传入的为当前i的值3, 因此线程0的编号被误改为3,这个线程未执行完,又启动了其他线程,比如线程1,但线程1传入的参数也是i的当前值3

 

如何才能让线程编号正确?

之所以不正确显示,是因为线程执行时,未能传入正确的i值。

因此,如果线程创建成功执行时,能传入正确值的话,这个问题就解决了。

怎样传入正确值呢?

handle[i]=(HANDLE)_beginthreadex(NULL,0,ThreadFun,&i,0,NULL);

i++;

创建线程i,此线程创建后,并没有立即执行,而是直接i++ 然后创建另一个线程。

如果在i++之前,能确保此线程执行的话,则能传入正确的i值。。。。

 

  handle[i]=(HANDLE)_beginthreadex(NULL,0,ThreadFun,&i,0,NULL);
  WaitForSingleObject(hSemaphore,INFINITE);
  i++;

 

WaitForSingleObject(hSemaphore,INFINITE);

直到hSemaphore有信号时,才往下继续执行,而只有当创建的线程执行时,Semaphore才有信号。

因为线程函数中有 设置信号的函数: ReleaseSemaphore(hSemaphore,1,NULL);

 

这样就保证了线程编号的正确。

 

int main(array<System::String ^> ^args)
{
	g_nNum=0;
	HANDLE handle[10];
	int i=0;

	//初始化关键段
	InitializeCriticalSection(&g_csThreadCore);
	//创建信号量
	hSemaphore=CreateSemaphore(NULL,0,1,NULL);


	while(i<THREAD_NUM)
	{
		handle[i]=(HANDLE)_beginthreadex(NULL,0,ThreadFun,&i,0,NULL);
		WaitForSingleObject(hSemaphore,INFINITE);
		i++;
	}

	WaitForMultipleObjects(THREAD_NUM,handle,TRUE,INFINITE);

	DeleteCriticalSection(&g_csThreadCore);
	CloseHandle(hSemaphore);
 

	cin>>i;
    return 0;
}

线程编号为0  全局资源值为1
线程编号为1  全局资源值为2
线程编号为2  全局资源值为3
线程编号为3  全局资源值为4
线程编号为4  全局资源值为5
线程编号为5  全局资源值为6
线程编号为6  全局资源值为7
线程编号为7  全局资源值为8
线程编号为8  全局资源值为9
线程编号为9  全局资源值为10

注意:线程函数除设置信号量外,还设置了临界区,临界区至多只有一个线程访问。

当一个线程进入临界区后,其它线程只能等待它退出临界区后,再访问。

这保证了,临界区内的全局数据不被多个线程同时修改,保证了临界区内的程序顺序执行

 

	EnterCriticalSection(&g_csThreadCore);
	g_nNum++;
	printf("线程编号为%d  全局资源值为%d\n",nThreadnum,g_nNum);
	LeaveCriticalSection(&g_csThreadCore);

假如: 去掉临界区

线程编号为3  全局资源值为4
线程编号为2  全局资源值为1
线程编号为0  全局资源值为2
线程编号为1  全局资源值为3
线程编号为8  全局资源值为5
线程编号为9  全局资源值为6
线程编号为5  全局资源值为8
线程编号为7  全局资源值为10
线程编号为6  全局资源值为7
线程编号为4  全局资源值为9

由此可见,全局资源顺序有误,甚至会有重复现象

这是因为:各个线程 同时访问全局变量,所导致的不一致

 

 

参考资料:http://blog.sina.com.cn/s/blog_6120646301012szj.html

抱歉!评论已关闭.