當前位置：首頁 » 編程語言 » c語言的線程同步

c語言的線程同步

發布時間: 2021-03-14 17:29:25

⑴ 如何用c語言實現多線程下生產者消費者互斥同步問題

整個程序以偽代碼形式給出，當做一個提示吧，這樣你就應該有思路了
生產者在存儲區滿時不能再生產，進入等待，消費者同理
完成同步互斥效果

/*----以下為代碼部分-----*/
//定義全局變數
int empty = 1;//信號量表示存儲單元空，可以生產產品
int full = 0;//信號量表示存儲單元空，不可以消費產品
//P操作
void P(int &mutex)
{
*mutex--;
if(*mutex<0)
{
//當前進程掛起的程序實現
}
}
//V操作
void V(int &mutex)
{
*mutex++;
if(*mutex <=0)
{
//喚醒等待中的進程程序實現
}
}
//生產者程序
void procer()
{
P(& empty);//若此時存儲區空，則可以生產，否則程序掛起等待
//生產一個產品操作
V(&full);//通知消費者進程，可以取產品
}
//消費者程序
void consumer(){
P(&full);//若此時存儲區不空，則可以取產品，否則消費者程序掛起等待
//取走一個產品操作
V(& empty);//通知生產者進程可以生產
}
//主函數
void main()
{
//分別調用生產者，消費者程序，順序不限，因為已經完成信號量的同步，若發生同步問題就會等待
procer()；
consumer()；
consumer()；
procer()；
………………
}

⑵ vc++線程同步

這個東西不是很好說啦，就拿具體的程序來說吧。就拿事件對象在線程同步中的應用來說吧，在VC下，我們用 HANDLE g_Event=CreateEvent(...)創建一個事件對象,CreateEvent函數中的有一個參數可以將此事件對象設置為自動重置還是人工重置。一般在此事件對象相關的線程函數中會有這樣的句子
while (TRUE)
{
WaitForSingleObject(g_Event,INFINITE)；
。。。
}
就說明這個線程在等待此事件對象的信號，事件對象有兩種狀態，一種是有信號狀態，一種是無信號狀態。當我們用函數SetEvent(g_Event)將事件對象變為有信號狀態時，就是你說的事件得到通知，這個線程的WaitForSingleObject函數就可以繼續向下執行，相當於線程進入可調度狀態（本來此線程的程序是卡在這個位置的，相當於不可調度）。而人工重置與自動重置的區別呢，重置就是將事件對象變成無信號狀態，人工重置就是使用函數ResetEvent(g_Event)將事件對象重置，而自動重置就是等待函數調用之後事件對象自動成為無信號的，不需人工調用ResetEvent函數。
以上都是我自己的理解，望指教

⑶ 為什麼要線程同步,說出線程同步的幾種方法

線程有時候回和其他線程共享一些資源，比如內存、資料庫等。當多個線程同時讀寫同一份共享資源的時候，可能會發生沖突。這時候，我們就需要引入線程「同步」機制，即各位線程之間要有順序使用，不能雜亂無章隨意使用。

線程同步的方法

1、wait():使一個線程處於等待狀態，並且釋放所持有的對象的lock。

(3)c語言的線程同步擴展閱讀：

在一般情況下，創建一個線程是不能提高程序的執行效率的，所以要創建多個線程。但是多個線程同時運行的時候可能調用線程函數，在多個線程同時對同一個內存地址進行寫入，由於CPU時間調度上的問題，寫入數據會被多次的覆蓋，所以就要使線程同步。

在多線程編程裡面，一些敏感數據不允許被多個線程同時訪問，此時就使用同步訪問技術，保證數據在任何時刻，最多有一個線程訪問，以保證數據的完整性。

⑷ C語言如何在線程間實現同步和互斥

線程之間的同步和互斥解決的問題是線程對共同資源進行訪問。Posix有兩種方式：
信號量和互斥鎖；信號量適用同時可用的資源為多個的情況；互斥鎖適用於線程可用的資源只有一個的情況
1、互斥鎖：互斥鎖是用加鎖的方式來控制對公共資源的原子操作(一旦開始進行就不會被打斷的操作)
互斥鎖只有上鎖和解鎖兩種狀態。互斥鎖可以看作是特殊意義的全局變數，因為在同一時刻只有一個線程能夠對互斥鎖進行操作；只有上鎖的進程才可以對公共資源進行訪問，其他進程只能等到該進程解鎖才可以對公共資源進行操作。
互斥鎖操作函數：
pthread_mutex_init();//初始化
pthread_mutex_lock();//上鎖參數：pthread_mutex_t *mutex
pthread_mutex_trylock();//判斷上鎖參數：pthread_mutex_t *mutex
pthread_mutex_unlock();//解鎖參數：pthread_mutex_t *mutex

pthread_mutex_release();//消除互斥鎖參數：pthread_mutex_t *mutex

互斥鎖分為快速互斥鎖、遞歸互斥鎖、檢錯互斥鎖；在 init 的時候確定
int pthread_mutex_t(pthread_mutex_t *mutex, const pthread_mutex_t mutexattr);
第一個參數：進行操作的鎖
mutexattr：鎖的類型，默認快速互斥鎖（阻塞）123456789

2、信號量：信號量本質上是一個計數器，在操作系統做用於PV原子操作；
P操作使計數器－1；V操作使計數器+1.
在互斥操作中可以是使用一個信號量；在同步操作中需要使用多個信號量，並設置不同的初始值安排它們順序執行
sem_init(); // 初始化操作
sem_wait(); // P操作，計數器減一；阻塞參數：sem_t *sem
sem_trywait(); // P操作，計數器減一；非阻塞參數：sem_t *sem
sem_post(); // V操作，計數器加一參數：sem_t *sem
sem_destroy(); // 銷毀信號量參數：sem_t *sem
sem_init(sem_t *sem, int pshared, int value);
pshared用於指定多少個進程共享；value初始值

⑸ 用C語言開多線程，如何「實現多個相同的子線程同時運行」

工作線程是處理後台工作的，創建一個線程非常簡單，只需要兩步：實線線程函數和開始線程.不需要由CWinThread派生類,你可以不加修改地使用CWinThread。
AfxBeginThread有兩種形式，一種是用來創建用戶界面線程的，另一種就是用來創建工作線程的.為了開始執行線程，只需要向AfxBeginThread提供下面的參數就可以了.
1.線程函數的地址
2.傳送到線程函數的參數
3.（可選的）線程的優先順序，可參閱::SetThreadPriority
4.（可選的）線程開始時候的狀態,可設置為CREATE_SUSPENEDE
5.（可選的）線程的安全屬性,請參閱SECURITY_ATTRIBUTES
實例代碼
UINT ThreadProc(LPVOID pParam)
{
return 0;//線程成功完成
}
CWinThread* AfxBeginThreadProc,//線程函數地址
LPVOID pParam,//線程參數
int nPriority=THREAD+PRIORITY_NOMAL,//線程優先順序
int nStackSize=0,//線程堆棧大小，默認為1M
DWORD dwCreateFlags=0,
LPSECURITY_ATTRIBUTES lpSecurityAttrs=NULL
);

⑹ c語言多個線程循環次數極大時如何減小時間差實現同步運行

使用線程同步技術，可以協調多線程的同步問題

⑺ C語言多線程線程同步可以干什麼

線程同步
比如你要操作大量數據，再有界面的情況下會卡住，實際上是在運行的，但是你會以為它卡死了，線程同步就是解決這類問題，讓操作量大的工作交給一個線程，界面的顯示交給另一個線程

⑻ c語言實例，linux線程同步的信號量方式謝謝

這么高的懸賞，實例放後面。信號量(sem),如同進程一樣，線程也可以通過信號量來實現通信，雖然是輕量級的。信號量函數的名字都以"sem_"打頭。線程使用的基本信號量函數有四個。

信號量初始化。
intsem_init(sem_t*sem,intpshared,unsignedintvalue);
這是對由sem指定的信號量進行初始化，設置好它的共享選項(linux只支持為0，即表示它是當前進程的局部信號量)，然後給它一個初始值VALUE。
等待信號量。給信號量減1，然後等待直到信號量的值大於0。
intsem_wait(sem_t*sem);
釋放信號量。信號量值加1。並通知其他等待線程。
intsem_post(sem_t*sem);
銷毀信號量。我們用完信號量後都它進行清理。歸還佔有的一切資源。
intsem_destroy(sem_t*sem);

#include<stdlib.h>
#include<stdio.h>
#include<unistd.h>
#include<pthread.h>
#include<semaphore.h>
#include<errno.h>
#definereturn_if_fail(p)if((p)==0){printf("[%s]:funcerror!/n",__func__);return;}
typedefstruct_PrivInfo
{
sem_ts1;
sem_ts2;
time_tend_time;
}PrivInfo;
staticvoidinfo_init(PrivInfo*thiz);
staticvoidinfo_destroy(PrivInfo*thiz);
staticvoid*pthread_func_1(PrivInfo*thiz);
staticvoid*pthread_func_2(PrivInfo*thiz);
intmain(intargc,char**argv)
{
pthread_tpt_1=0;
pthread_tpt_2=0;
intret=0;
PrivInfo*thiz=NULL;
thiz=(PrivInfo*)malloc(sizeof(PrivInfo));
if(thiz==NULL)
{
printf("[%s]:Failedtomallocpriv./n");
return-1;
}
info_init(thiz);
ret=pthread_create(&pt_1,NULL,(void*)pthread_func_1,thiz);
if(ret!=0)
{
perror("pthread_1_create:");
}
ret=pthread_create(&pt_2,NULL,(void*)pthread_func_2,thiz);
if(ret!=0)
{
perror("pthread_2_create:");
}
pthread_join(pt_1,NULL);
pthread_join(pt_2,NULL);
info_destroy(thiz);
return0;
}
staticvoidinfo_init(PrivInfo*thiz)
{
return_if_fail(thiz!=NULL);
thiz->end_time=time(NULL)+10;
sem_init(&thiz->s1,0,1);
sem_init(&thiz->s2,0,0);
return;
}
staticvoidinfo_destroy(PrivInfo*thiz)
{
return_if_fail(thiz!=NULL);
sem_destroy(&thiz->s1);
sem_destroy(&thiz->s2);
free(thiz);
thiz=NULL;
return;
}
staticvoid*pthread_func_1(PrivInfo*thiz)
{
return_if_fail(thiz!=NULL);
while(time(NULL)<thiz->end_time)
{
sem_wait(&thiz->s2);
printf("pthread1:pthread1getthelock./n");
sem_post(&thiz->s1);
printf("pthread1:pthread1unlock/n");
sleep(1);
}
return;
}
staticvoid*pthread_func_2(PrivInfo*thiz)
{
return_if_fail(thiz!=NULL);
while(time(NULL)<thiz->end_time)
{
sem_wait(&thiz->s1);
printf("pthread2:pthread2gettheunlock./n");
sem_post(&thiz->s2);
printf("pthread2:pthread2unlock./n");
sleep(1);
}
return;
}

⑼ C語言如何實現多線程同時運行

1、點擊菜單欄的「Project」選項卡，下拉列表的最後一項「Project options...」是對當前工程的的屬性進行設置的。

⑽ 如何用c語言編寫同步與互斥線程 csdn

pthread_create(pthread_t *thread, pthread_attr_t * attr, void *(*start_routine)(void *),void *arg);創建線程（默認為同步線程）
線程的互斥函數有：互斥函數的初始化pthread_mutex_init（），互斥函數的鎖定函數pthread_mutex_lock（），互斥函數的預鎖定函數pthread_mutex_trylock（），互斥函數的解鎖函數pthread_mutex_unlock（），互斥函數的銷毀函數pthread_mutex_destroy（）

閱讀全文

c語言的線程同步

與c語言的線程同步相關的閱讀推薦