c語言線程有關函數 c語言中線程
C語言線程函數參數問題
·線程創(chuàng)建
成都創(chuàng)新互聯(lián)公司長期為數千家客戶提供的網站建設服務，團隊從業(yè)經驗10年，關注不同地域、不同群體，并針對不同對象提供差異化的產品和服務；打造開放共贏平臺，與合作伙伴共同營造健康的互聯(lián)網生態(tài)環(huán)境。為烏蘭企業(yè)提供專業(yè)的網站制作、做網站，烏蘭網站改版等技術服務。擁有十載豐富建站經驗和眾多成功案例,為您定制開發(fā)。
函數原型：int pthread_create(pthread_t *restrict tidp,const pthread_attr_t *restrict attr,void *(*start_rtn)(void),void *restrict arg);
返回值：若是成功建立線程返回0，否則返回錯誤的編號。
形式參數：pthread_t *restrict tidp要創(chuàng)建的線程的線程id指針；
const pthread_attr_t *restrict attr創(chuàng)建線程時的線程屬性；
void* (start_rtn)(void)返回值是void類型的指針函數；
void *restrict arg start_rtn的形參。 =====這個地方就可以傳參數，
注意，這個地方是個指針，要想傳多個參數，可以定義一個結構體，把要傳的參數包起來，傳結構體的地址就ok
請問用C語言在windows上建立多線程需要用什么函數最好，
#includewindows.h
#includefstream.h
#includestdio.h
#includestring
#includeconio.h
//定義一些常量；
//本程序允許的最大臨界區(qū)數；
#define MAX_BUFFER_NUM 10
//秒到微秒的乘法因子；
#define INTE_PER_SEC 1000
//本程序允許的生產和消費線程的總數；
#define MAX_THREAD_NUM 64
//定義一個結構，記錄在測試文件中指定的每一個線程的參數
struct ThreadInfo
{
int serial; //線程序列號
char entity; //是P還是C
double delay; //線程延遲
int thread_request[MAX_THREAD_NUM]; //線程請求隊列
int n_request; //請求個數
};
//全局變量的定義
//臨界區(qū)對象的聲明,用于管理緩沖區(qū)的互斥訪問；
CRITICAL_SECTION PC_Critical[MAX_BUFFER_NUM];
int Buffer_Critical[MAX_BUFFER_NUM]; //緩沖區(qū)聲明，用于存放產品；
HANDLE h_Thread[MAX_THREAD_NUM]; //用于存儲每個線程句柄的數組；
ThreadInfo Thread_Info[MAX_THREAD_NUM]; //線程信息數組；
HANDLE empty_semaphore; //一個信號量；
HANDLE h_mutex; //一個互斥量；
DWORD n_Thread = 0; //實際的線程的數目；
DWORD n_Buffer_or_Critical; //實際的緩沖區(qū)或者臨界區(qū)的數目；
HANDLE h_Semaphore[MAX_THREAD_NUM]; //生產者允許消費者開始消費的信號量；
//生產消費及輔助函數的聲明
void Produce(void *p);
void Consume(void *p);
bool IfInOtherRequest(int);
int FindProducePositon();
int FindBufferPosition(int);
int main(void)
{
//聲明所需變量；
DWORD wait_for_all;
ifstream inFile;
//初始化緩沖區(qū)；
for(int i=0;i MAX_BUFFER_NUM;i++)
Buffer_Critical[i] = -1;
//初始化每個線程的請求隊列；
for(int j=0;jMAX_THREAD_NUM;j++){
for(int k=0;kMAX_THREAD_NUM;k++)
Thread_Info[j].thread_request[k] = -1;
Thread_Info[j].n_request = 0;
}
//初始化臨界區(qū)；
for(i =0;i MAX_BUFFER_NUM;i++)
InitializeCriticalSection(PC_Critical[i]);
//打開輸入文件，按照規(guī)定的格式提取線程等信息；
inFile.open("test.txt");
//從文件中獲得實際的緩沖區(qū)的數目；
inFile n_Buffer_or_Critical;
inFile.get();
printf("輸入文件是:\n");
//回顯獲得的緩沖區(qū)的數目信息；
printf("%d \n",(int) n_Buffer_or_Critical);
//提取每個線程的信息到相應數據結構中；
while(inFile){
inFile Thread_Info[n_Thread].serial;
inFile Thread_Info[n_Thread].entity;
inFile Thread_Info[n_Thread].delay;
char c;
inFile.get(c);
while(c!='\n' !inFile.eof()){
inFile Thread_Info[n_Thread].thread_request[Thread_Info[n_Thread].n_request++];
inFile.get(c);
}
n_Thread++;
}
//回顯獲得的線程信息，便于確認正確性；
for(j=0;j(int) n_Thread;j++){
int Temp_serial = Thread_Info[j].serial;
char Temp_entity = Thread_Info[j].entity;
double Temp_delay = Thread_Info[j].delay;
printf(" \n thread%2d %c %f ",Temp_serial,Temp_entity,Temp_delay);
int Temp_request = Thread_Info[j].n_request;
for(int k=0;kTemp_request;k++)
printf(" %d ", Thread_Info[j].thread_request[k]);
coutendl;
}
printf("\n\n");
//創(chuàng)建在模擬過程中幾個必要的信號量
empty_semaphore=CreateSemaphore(NULL,n_Buffer_or_Critical,n_Buffer_or_Critical,
"semaphore_for_empty");
h_mutex = CreateMutex(NULL,FALSE,"mutex_for_update");
//下面這個循環(huán)用線程的ID號來為相應生產線程的產品讀寫時所
//使用的同步信號量命名；
for(j=0;j(int)n_Thread;j++){
std::string lp ="semaphore_for_produce_";
int temp =j;
while(temp){
char c = (char)(temp%10);
lp+=c;
temp/=10;
}
h_Semaphore[j+1]=CreateSemaphore(NULL,0,n_Thread,lp.c_str());
}
//創(chuàng)建生產者和消費者線程；
for(i =0;i (int) n_Thread;i++){
if(Thread_Info[i].entity =='P')
h_Thread[i]= CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(Produce),
(Thread_Info[i]),0,NULL);
else
h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(Consume),
(Thread_Info[i]),0,NULL);
}
//主程序等待各個線程的動作結束；
wait_for_all = WaitForMultipleObjects(n_Thread,h_Thread,TRUE,-1);
printf(" \n \nALL Producer and consumer have finished their work. \n");
printf("Press any key to quit!\n");
_getch();
return 0;
}
//確認是否還有對同一產品的消費請求未執(zhí)行；
bool IfInOtherRequest(int req)
{
for(int i=0;in_Thread;i++)
for(int j=0;jThread_Info[i].n_request;j++)
if(Thread_Info[i].thread_request[j] == req)
return TRUE;
return FALSE;
}
//找出當前可以進行產品生產的空緩沖區(qū)位置；
int FindProducePosition()
{
int EmptyPosition;
for (int i =0;in_Buffer_or_Critical;i++)
if(Buffer_Critical[i] == -1){
EmptyPosition = i;
//用下面這個特殊值表示本緩沖區(qū)正處于被寫狀態(tài)；
Buffer_Critical[i] = -2;
break;
}
return EmptyPosition;
}
//找出當前所需生產者生產的產品的位置；
int FindBufferPosition(int ProPos)
{
int TempPos;
for (int i =0 ;in_Buffer_or_Critical;i++)
if(Buffer_Critical[i]==ProPos){
TempPos = i;
break;
}
return TempPos;
}
//生產者進程
void Produce(void *p)
{
//局部變量聲明；
DWORD wait_for_semaphore,wait_for_mutex,m_delay;
int m_serial;
//獲得本線程的信息；
m_serial = ((ThreadInfo*)(p))-serial;
m_delay = (DWORD)(((ThreadInfo*)(p))-delay *INTE_PER_SEC);
Sleep(m_delay);
//開始請求生產
printf("Producer %2d sends the produce require.\n",m_serial);
//確認有空緩沖區(qū)可供生產，同時將空位置數empty減1；用于生產者和消費者的同步；
wait_for_semaphore = WaitForSingleObject(empty_semaphore,-1);
//互斥訪問下一個可用于生產的空臨界區(qū)，實現寫寫互斥；
wait_for_mutex = WaitForSingleObject(h_mutex,-1);
int ProducePos = FindProducePosition();
ReleaseMutex(h_mutex);
//生產者在獲得自己的空位置并做上標記后，以下的寫操作在生產者之間可以并發(fā)；
//核心生產步驟中，程序將生產者的ID作為產品編號放入，方便消費者識別;
printf("Producer %2d begin to produce at position %2d.\n",m_serial,ProducePos);
Buffer_Critical[ProducePos] = m_serial;
printf("Producer %2d finish producing :\n ",m_serial);
printf(" position[ %2d ]:%3d \n" ,ProducePos,Buffer_Critical[ProducePos]);
//使生產者寫的緩沖區(qū)可以被多個消費者使用，實現讀寫同步；
ReleaseSemaphore(h_Semaphore[m_serial],n_Thread,NULL);
}
//消費者進程
void Consume(void * p)
{
//局部變量聲明；
DWORD wait_for_semaphore,m_delay;
int m_serial,m_requestNum; //消費者的序列號和請求的數目；
int m_thread_request[MAX_THREAD_NUM];//本消費線程的請求隊列；
//提取本線程的信息到本地；
m_serial = ((ThreadInfo*)(p))-serial;
m_delay = (DWORD)(((ThreadInfo*)(p))-delay *INTE_PER_SEC);
m_requestNum = ((ThreadInfo *)(p))-n_request;
for (int i = 0;im_requestNum;i++)
m_thread_request[i] = ((ThreadInfo*)(p))-thread_request[i];
Sleep(m_delay);
//循環(huán)進行所需產品的消費
for(i =0;im_requestNum;i++){
//請求消費下一個產品
printf("Consumer %2d request to consume %2d product\n",m_serial,m_thread_request[i]);
//如果對應生產者沒有生產，則等待；如果生產了,允許的消費者數目-1；實現了讀寫同步；
wait_for_semaphore=WaitForSingleObject(h_Semaphore[m_thread_request[i]],-1);
//查詢所需產品放到緩沖區(qū)的號
int BufferPos=FindBufferPosition(m_thread_request[i]);
//開始進行具體緩沖區(qū)的消費處理，讀和讀在該緩沖區(qū)上仍然是互斥的；
//進入臨界區(qū)后執(zhí)行消費動作；并在完成此次請求后，通知另外的消費者本處請求已
//經滿足；同時如果對應的產品使用完畢，就做相應處理；并給出相應動作的界面提
//示；該相應處理指將相應緩沖區(qū)清空，并增加代表空緩沖區(qū)的信號量；
EnterCriticalSection(PC_Critical[BufferPos]);
printf("Consumer%2d begin to consume %2d product \n",m_serial,m_thread_request[i]);
((ThreadInfo*)(p))-thread_request[i] =-1;
if(!IfInOtherRequest(m_thread_request[i])){
Buffer_Critical[BufferPos] = -1;//標記緩沖區(qū)為空；
printf("Consumer%2d finish consuming %2d:\n ",m_serial,m_thread_request[i]);
printf(" position[ %2d ]:%3d \n" ,BufferPos,Buffer_Critical[BufferPos]);
ReleaseSemaphore(empty_semaphore,1,NULL);
}
else{
printf("Consumer %2d finish consuming product %2d\n ",m_serial,m_thread_request[i]);
}
//離開臨界區(qū)
LeaveCriticalSection(PC_Critical[BufferPos]);
}
}
看函數就行
C語言怎么寫線程代碼
通常使用CreateThread函數來創(chuàng)建新的線程.(Unix下使用pthread_create函數)
首先指出,線程與線程之間,是并列關系,不會存在"父子線程"的概念.
在Windows平臺下,CreateThread函數包含在 Windows.h 文件內,包含此文件即可正常使用.
以下為CreateThread函數的聲明:
HANDLE CreateThread(
LPSECURITY_ATTRIBUTES lpThreadAttributes,//指向安全性屬性描述結構體的
//指針,通?？梢院雎缘?
SIZE_T dwStackSize,//指定新線程初始的棧大小,若不關心,可以用0填充,來要求使用
//默認值
LPTHREAD_START_ROUTINE lpStartAddress,//用來充當線程的函數的指針.
LPVOID lpParameter,//要傳遞給函數的參數,這個值本身就是那個參數,而不是參數的地址
DWORD dwCreationFlags,//創(chuàng)建的方式,0表示正常,創(chuàng)建后立即開始運行
LPDWORD lpThreadId//用來接受函數反饋的線程ID的指針.
);
用來充當新的線程的函數格式:
DWORD WINAPI ThreadProc(LPVOID);
CreateThread函數若成功了,返回新線程的句柄,若失敗了,則返回NULL.
若用CREATE_SUSPENDED填充dwCreation Flags則創(chuàng)建的線程先掛起來,并不直接開始運行,要用ResumeThread函數恢復線程,才能繼續(xù)運行.
c語言中process.h是什么意思，像stdio.h是輸入輸出似的，它包含那些函數？
process.h說明進程管理的各個函數，spawn…和EXEC …函數的結構說明。
提供了兩個對多線程進行支持的函數，即線程的創(chuàng)建和終結
?沒有對線程掛起和恢復進行操作的函數，通常，這兩項功能使用win32?api完成。
2.關于這個里面都包含什么吧你自己看看這個吧！我表示無力打上來
?
本文名稱：c語言線程有關函數 c語言中線程
分享地址：http://m.jiaotiyi.com/article/doegioi.html