pv操作c語言
『壹』 用c語言編程實現P、V原語並用P、V原語哲學家就餐問題
這個是操作系統課的問題吧，我沒做過哲學家這個程序，不過我用c語言做過生產者與消費者，大概差不多，pv操作時用windows api函數完成的。
『貳』 c語言指令有哪些啊
第一章：緒論？
內核版本號格式：x.y.zz-www／x為主版本號，y為次版本號，zz為次次版本號，www為發行號／次版本號改變說明內核有重大變革，其偶數為穩定版本，奇數為尚在開發中的版本
第二章：基礎？
文件種類：-：txt，二進制／d：目錄／l：鏈接文件（link）／b：區塊設備文件／c：字元設備文件／p：管道
目錄結構：bin：可執行／boot：開機引導／dev：設備文件／etc：系統配置文件／lib：庫文件／mnt：設備掛載點／var：系統日誌／
命令：rmdir：刪除空目錄／find [path] [expression]／touch命令還可以修改指定文件的最近一次訪問時間／tar -czvf usr.tar.gz path／tar –zxvf usr.tar.gz／tar –cjvf usr.tar.bz2 path／tar –jxvf usr.tar.bz2
gcc：預處理：-g／I在頭文件搜索路徑中添加目錄，L在庫文件搜索路徑中
gdb：設置斷點：b／查看斷點信息：info
Makefile：make –f other_makefile／<：第一個依賴文件的名稱／@：目標文件的完整名稱／^：所有不重復的依賴文件／+：所有依賴文件（可能重復）
第三章：文件IO
read：read(fd, temp, size); ／讀fd中長度為size的值到temp／返回0表示file為NULL
write：write(fd, buf, buf_size); ／寫長度為buf_size的buf內容到fd中
lseek：lseek(fd, offset, SEEK_SET); ／從文件開頭向後增加offset個位移量
unlink：從文件系統中刪除一個名字
open1：int open(const char * pathname, int flags, mode_t mode);／flags為讀寫方式／mode為許可權設置／O_EXCL：測試文件是否存在／O_TRUNC：若存在同名文件則刪除之並新建
open2：注意O_NONBLOCK
mmap.1：void *mmap(void *start, size_t length, int prot, int flags, int fd, off_t offsize);
mmap.2：mmap(start_addr, flength, PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0);
fcntl：上鎖／int fcntl(int fd, int cmd, struct flock * lock);／對誰；做什麼；設置所做內容
select：fd_max+1，回傳讀狀況，回傳寫狀況，回傳異常，select等待的時間／NULL為永遠等待／0為從不等待／凡需某狀況則用之，反則(fd_set *)NULL之
FD_*那幾個函數……
一般出錯則返回-1
第四章：文件與目錄
硬鏈接與符號鏈接？
chdir改變目錄
0：in／1：out／2：err
第五章：內存管理
可執行文件存儲時：代碼區、數據區和未初始化區
棧：by編譯器，向低址擴展，連續，效率高／堆：by程序員
/etc/syslog.conf，系統log記錄文件／優先順序為-20時最高
第六章：進程和信號
程序代碼、數據、變數、文件描述符和環境／init的pid為1
execl族：int execl(const char * path, const char * arg, ....);／path即可執行文件的路徑，一般為.／最後一個參數以NULL結束
waitpid：waitpid(pid_t pid,int * status,int options);／option：一般用WNOHANG，沒有已經結束的子進程則馬上返回，不等待
kill：int kill(pid_t pid,int sig);／發送信號sig給pid
void (*signal(int signum, void(* handler)(int)))(int);／第一個參數被滿足時，執行handler／第一個參數常用：SIG_IGN：忽略信號／SIG_DFL：恢復默認信號
第七章：線程
sem_init(sem_t *sem, int pshared, unsigned int value)／pshared為0／value即初始值
第八章：管道
1：write／0：read
第九章：信號量、共享內存和消息隊列
臨界資源：操作系統中只允許一個進程訪問的資源／臨界區：訪問臨界資源的那段代碼
信號量：建立聯系（semget），然後初始化，PV操作，最後destroy
共享內存沒有提供同步機制
第十章：套接字
UDP：無連接協議，無主客端的區分／實時性
TCP：位元組流／數據可靠性／網路可靠性
數據報：SOCK_STREAM／SOCK_DGRAM
其它
管道一章的both_pipe即父子進程間的全雙工管道通訊
關繫到信號和互斥的伺服器-客戶端程序
線程一章的class的multi_thread文件夾下的thread8.c
int main(void)
{
int data_processed;
int file_pipes_1[2];
int file_pipes_2[2];
char buffer[BUFSIZ + 1];
const char some_data[] = "123";
const char ch2p[] = "this is the string from child to the parent!";
const char p2ch[] = "this is the string from parent to the child!";
pid_t fork_result;
memset(buffer,'\0',sizeof(buffer));
if(pipe(file_pipes_1) == 0){
if(pipe(file_pipes_2) == 0){
fork_result = fork();
switch(fork_result){
case -1:
perror("fork error");
exit(EXIT_FAILURE);
case 0://child
close(file_pipes_1[1]);
close(file_pipes_2[0]);
printf("in the child!\n");
read(file_pipes_1[0],buffer, BUFSIZ);
printf("in the child, read_result is \"%s\"\n",buffer);
write(file_pipes_2[1],ch2p, sizeof(ch2p));
printf("in the child, write_result is \"%s\"\n",ch2p);
exit(EXIT_SUCCESS);
default://parent
close(file_pipes_1[0]);
close(file_pipes_2[1]);
printf("in the parent!\n");
write(file_pipes_1[1], p2ch, sizeof(p2ch));
printf("in the parent, write_result is \"%s\"\n",p2ch);
read(file_pipes_2[0],buffer, BUFSIZ);
printf("in the parent, read_result is \"%s\"\n",buffer);
exit(EXIT_SUCCESS);
}
}
}
}
#ifndef DBG
#define DBG
#endif
#undef DBG
#ifdef DBG
#define PRINTF(fmt, args...) printf("file->%s line->%d: " \
fmt, __FILE__, __LINE__, ##args)
#else
#define PRINTF(fmt, args...) do{}while(0);
#endif
int main(void)
{
PRINTF("%s\n", "hello!");
fprintf(stdout, "hello hust!\n");
return 0;
}
#define N 5
#define MAX 5
int nput = 0;
char buf[MAX][50];
char *buffer = "";
char buf_r[100];
sem_t mutex,full,avail;
void *proctor(void *arg);
void *consumer(void *arg);
int i = 0;
int main(int argc, char **argv)
{
int cnt = -1;
int ret;
int nput = 0;
pthread_t id_proce[10];
pthread_t id_consume;
ret = sem_init(&mutex, 0, 1);
ret = sem_init(&avail, 0, N);
ret = sem_init(&full, 0, 0);
for(cnt = 0; cnt < 6; cnt ++ ){
//pthread_create(&id_proce[cnt], NULL, (void *)proctor, &cnt);
pthread_create(&id_proce[cnt], NULL, (void *)proctor, (void *)cnt);
}
pthread_create(&id_consume, NULL, (void *)consumer, NULL);
for(cnt = 0; cnt < 6; cnt ++){
pthread_join(id_proce[cnt], NULL);
}
pthread_join(id_consume,NULL);
sem_destroy(&mutex);
sem_destroy(&avail);
sem_destroy(&full);
exit(EXIT_SUCCESS);
}
void *proctor(void *arg)
{
while(1){
sem_wait(&avail);
sem_wait(&mutex);
if(nput >= MAX * 3){
sem_post(&avail);
//sem_post(&full);
sem_post(&mutex);
return NULL;
}
sscanf(buffer + nput, "%s", buf[nput % MAX]);
//printf("write[%d] \"%s\" to the buffer[%d]\n", (*(int*)arg), buf[nput % MAX],nput % MAX);
printf("write[%d] \"%s\" to the buffer[%d]\n", (int)arg, buf[nput % MAX],nput % MAX);
nput ++;
printf("nput = %d\n", nput);
sem_post(&mutex);
sem_post(&full);
}
return NULL;
}
void *consumer(void *arg)
{
int nolock = 0;
int ret, nread, i;
for(i = 0; i < MAX * 3; i++)
{
sem_wait(&full);
sem_wait(&mutex);
memset(buf_r, 0, sizeof(buf_r));
strncpy(buf_r, buf[i % MAX], sizeof(buf[i % MAX]));
printf("read \"%s\" from the buffer[%d]\n\n",buf_r, i % MAX);
sem_post(&mutex);
sem_post(&avail);
//sleep(1);
}
return NULL;
}
『叄』 用C語言實現--生產者與消費者的問題(PV操作)
這個問題蠻好的
我給你個程序
給我加分啊
#include
<windows.h>
#include
<stdio.h>
#include
<stdlib.h>
typedef
HANDLE
Semaphore;
//
信號量的Windows原型
#define
P(S)
WaitForSingleObject(S,
INFINITE)
//
定義Windows下的P操作
#define
V(S)
ReleaseSemaphore(S,
1,
NULL)
//
定義Windows下的V操作
#define
rate
1000
#define
CONSUMER_NUM
10
/*
消費者個數
*/
#define
PRODUCER_NUM
10
/*
生產者個數
*/
#define
BUFFER_NUM
4
/*
緩沖區個數
*/
char
*thing[10]
=
{"豬臉",
"牛鞭",
"羊腰",
"驢蹄",
"狼心",
"狗肺",
"猴肝",
"老虎屁股",
"大象肚",
"河馬大腸"};
struct
Buffer
{
int
proct[BUFFER_NUM];
//
緩沖區
int
start,
end;
//
兩個指針
}
g_buf;
Semaphore
g_semBuffer,
g_semProct,
g_mutex;
//
消費者線程
DWORD
WINAPI
Consumer(LPVOID
para)
{
//
i表示第i個消費者
int
i
=
*(int
*)para;
int
ptr;
//
待消費的內容的指針
printf("
豬頭-%03d:
豬頭我來啦！\n",
i);
Sleep(300);
while
(1)
{
printf("
豬頭-%03d:
我要吃.........!\n",
i);
//
等待產品
P(g_semProct);
//
有產品，先鎖住緩沖區
g_buf
P(g_mutex);
//
記錄消費的物品
ptr
=
g_buf.start;
//
再移動緩沖區指針
g_buf.start
=
(g_buf.start+1)%BUFFER_NUM;
//
讓其他消費者或生產者使用
g_buf
V(g_mutex);
printf("
豬頭-%03d:
我吃
buf[%d]
=
%s\n",
i,
ptr,
thing[g_buf.proct[ptr]]);
Sleep(rate*rand()%10+110);
//
消費完畢，並釋放一個緩沖
printf("
豬頭-%03d:
我爽了！
buf[%d]
=
%s\n",
i,
ptr,
thing[g_buf.proct[ptr]]);
V(g_semBuffer);
}
return
0;
}
//
生產者線程
DWORD
WINAPI
Procer(LPVOID
para)
{
int
i
=
*(int
*)para
-
CONSUMER_NUM;
int
ptr;
int
data;
//
產品
printf("工作狂-%03d:
我來啦！\n",
i);
Sleep(300);
while
(1)
{
printf("工作狂-%03d:
我乾乾干…………\n",
i);
Sleep(rate*rand()%10+110);
data
=
rand()%10;
printf("工作狂-%03d:
搞出一個東西
data
=
%s!\n",
i,
thing[data]);
//
等待存放空間
P(g_semBuffer);
//
有地方，先鎖住緩沖區
g_buf
P(g_mutex);
//
記錄消費的物品
ptr
=
g_buf.end;
//
再移動緩沖區指針
g_buf.end
=
(g_buf.end+1)%BUFFER_NUM;
//
讓其他消費者或生產者使用
g_buf
V(g_mutex);
printf("工作狂-%03d:
擱到
buf[%d]
=
%s\n",
i,
ptr,
thing[data]);
g_buf.proct[ptr]
=
data;
Sleep(rate/2*rand()%10+110);
//
放好了完畢，釋放一個產品
printf("工作狂-%03d:
buf[%d]
=
%s
放好了，大家吃！\n",
i,
ptr,
thing[g_buf.proct[ptr]]);
V(g_semProct);
}
return
0;
}
int
main(int
argc,
char
*argv[])
{
//
線程技術，前面為消費者線程，後面為生產者線程
HANDLE
hThread[CONSUMER_NUM+PRODUCER_NUM];
//
線程計數
//srand(time());
DWORD
tid;
int
i=0;
//
初始化信號量
g_mutex
=
CreateSemaphore(NULL,
BUFFER_NUM,
BUFFER_NUM,
"mutexOfConsumerAndProcer");
g_semBuffer
=
CreateSemaphore(NULL,
BUFFER_NUM,
BUFFER_NUM,
"BufferSemaphone");
g_semProct
=
CreateSemaphore(NULL,
0,
BUFFER_NUM,
"ProctSemaphone");
if
(
!g_semBuffer
||
!g_semProct
||
!g_mutex)
{
printf("Create
Semaphone
Error!\n");
return
-1;
}
int
totalThreads
=
CONSUMER_NUM+PRODUCER_NUM;
//
開啟消費者線程
printf("先請豬頭們上席！\n");
for
(i=0;
i<CONSUMER_NUM;
i++)
{
hThread[i]
=
CreateThread(NULL,
0,
Consumer,
&i,
0,
&tid);
if
(
hThread[i]
)
WaitForSingleObject(hThread[i],
10);
}
printf("廚子們就位！\n");
for
(;
i<totalThreads;
i++)
{
hThread[i]
=
CreateThread(NULL,
0,
Procer,
&i,
0,
&tid);
if
(
hThread[i]
)
WaitForSingleObject(hThread[i],
10);
}
//
生產者和消費者的執行
WaitForMultipleObjects(totalThreads,
hThread,
TRUE,
INFINITE);
return
0;
}
『肆』 用C語言實現PV操作生產者消費者關系
#include <windows.h>
#include <stdio.h>
#include <stdlib.h>
typedef HANDLE Semaphore; // 信號量的Windows原型
#define P(S) WaitForSingleObject(S, INFINITE) // 定義Windows下的P操作
#define V(S) ReleaseSemaphore(S, 1, NULL) // 定義Windows下的V操作
#define rate 1000
#define CONSUMER_NUM 10 /* 消費者個數 */
#define PRODUCER_NUM 10 /* 生產者個數 */
#define BUFFER_NUM 4 /* 緩沖區個數 */
char *thing[10] = ;
struct Buffer
{
int proct[BUFFER_NUM]; // 緩沖區
int start, end; // 兩個指針
} g_buf;
Semaphore g_semBuffer, g_semProct, g_mutex;
// 消費者線程
DWORD WINAPI Consumer(LPVOID para)
{
// i表示第i個消費者
int i = *(int *)para;
int ptr; // 待消費的內容的指針
printf(" 豬頭-%03d: 豬頭我來啦！\n", i);
Sleep(300);
while (1)
{
printf(" 豬頭-%03d: 我要吃.........!\n", i);
// 等待產品
P(g_semProct);
// 有產品，先鎖住緩沖區 g_buf
P(g_mutex);
// 記錄消費的物品
ptr = g_buf.start;
// 再移動緩沖區指針
g_buf.start = (g_buf.start+1)%BUFFER_NUM;
// 讓其他消費者或生產者使用 g_buf
V(g_mutex);
printf(" 豬頭-%03d: 我吃 buf[%d] = %s\n", i, ptr, thing[g_buf.proct[ptr]]);
Sleep(rate*rand()%10+110);
// 消費完畢，並釋放一個緩沖
printf(" 豬頭-%03d: 我爽了！ buf[%d] = %s\n", i, ptr, thing[g_buf.proct[ptr]]);
V(g_semBuffer);
}
return 0;
}
// 生產者線程
DWORD WINAPI Procer(LPVOID para)
{
int i = *(int *)para - CONSUMER_NUM;
int ptr;
int data; // 產品
printf("工作狂-%03d: 我來啦！\n", i);
Sleep(300);
while (1)
{
printf("工作狂-%03d: 我乾乾干…………\n", i);
Sleep(rate*rand()%10+110);
data = rand()%10;
printf("工作狂-%03d: 搞出一個東西 data = %s!\n", i, thing[data]);
// 等待存放空間
P(g_semBuffer);
// 有地方，先鎖住緩沖區 g_buf
P(g_mutex);
// 記錄消費的物品
ptr = g_buf.end;
// 再移動緩沖區指針
g_buf.end = (g_buf.end+1)%BUFFER_NUM;
// 讓其他消費者或生產者使用 g_buf
V(g_mutex);
printf("工作狂-%03d: 擱到 buf[%d] = %s\n", i, ptr, thing[data]);
g_buf.proct[ptr] = data;
Sleep(rate/2*rand()%10+110);
// 放好了完畢，釋放一個產品
printf("工作狂-%03d: buf[%d] = %s 放好了，大家吃！\n", i, ptr, thing[g_buf.proct[ptr]]);
V(g_semProct);
}
return 0;
}
int main(int argc, char *argv[])
{
// 線程技術，前面為消費者線程，後面為生產者線程
HANDLE hThread[CONSUMER_NUM+PRODUCER_NUM]; // 線程計數
//srand(time());
DWORD tid;
int i=0;
// 初始化信號量
g_mutex = CreateSemaphore(NULL, BUFFER_NUM, BUFFER_NUM, "mutexOfConsumerAndProcer");
g_semBuffer = CreateSemaphore(NULL, BUFFER_NUM, BUFFER_NUM, "BufferSemaphone");
g_semProct = CreateSemaphore(NULL, 0, BUFFER_NUM, "ProctSemaphone");
if ( !g_semBuffer || !g_semProct || !g_mutex)
{
printf("Create Semaphone Error!\n");
return -1;
}
int totalThreads = CONSUMER_NUM+PRODUCER_NUM;
// 開啟消費者線程
printf("先請豬頭們上席！\n");
for (i=0; i<CONSUMER_NUM; i++)
{
hThread[i] = CreateThread(NULL, 0, Consumer, &i, 0, &tid);
if ( hThread[i] ) WaitForSingleObject(hThread[i], 10);
}
printf("廚子們就位！\n");
for (; i<totalThreads; i++)
{
hThread[i] = CreateThread(NULL, 0, Procer, &i, 0, &tid);
if ( hThread[i] ) WaitForSingleObject(hThread[i], 10);
}
// 生產者和消費者的執行
WaitForMultipleObjects(totalThreads, hThread, TRUE, INFINITE);
return 0;
}
『伍』 linux中pv操作偽代碼怎麼寫
//演算法描述語言使用基於C語言的偽代碼
//演算法思想：根據樓主的要求「為防止數的丟失和重復取同一個數」可以看出，進程A、進程B、進程C三者之間應該是互斥的關系。那麼問題所限定的使用帶埋信號量的方式來管理的潛藏意思，就是要利用PV
原語實現並發進程在資源爭奪中拆薯有效互斥。
//而具體實現的目標是「防止數旅行者的丟失」和「重復取同一個數」。由於本人不才，只討論單任務系統下的狀況。
//「數的丟失」的情況主要是進程A產生了隨即變數給F後，但在進程B或者進程C處理之前又獲得處理機的使用權而覆蓋了之前那個未被處理過的F中的數——進程A連續獲得處理機的使用權，而進程B、進