Linux System V IPC 信號量

来源:http://www.cnblogs.com/xiaojiang1025/archive/2016/10/07/5936135.html
-Advertisement-
Play Games

模型 1. 獲取key ftok() 2. 創建/獲取信號量集 semget() 3. 初始化信號量集 semctl() 4. 操作信號量集 semop() 3. 刪除信號量集 semctl() 使用的頭文件: ftok() pathname :文件名 proj_id : 1~255的一個數,表示p ...


模型

  1. 獲取key ftok()
  2. 創建/獲取信號量集 semget()
  3. 初始化信號量集 semctl()
  4. 操作信號量集 semop()
  5. 刪除信號量集 semctl()

使用的頭文件:

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>

ftok()

//獲取key值, key值是System V IPC的標識符,成功返回key,失敗返回-1設errno
//同pathname+同 proj_id==>同key_t;
key_t ftok(const char *pathname, int proj_id);

pathname :文件名
proj_id: 1~255的一個數,表示project_id

key_t key=ftok(".",100);    //“.”就是一個存在且可訪問的路徑, 100是假設的proj_id
    if(-1==key)
        perror("ftok"),exit(-1);

semget():

//創建/獲取一個信號量集,成功返回semid,失敗返回-1
int semget(key_t key, int nsems, int semflg);

nsems: 信號量集的大小/信號量的個數,0表示獲取已經存在的信號量集
semflg

  • IPC_CREAT :若不存在則創建, 需要在msgflg中"|許可權信息"; 若存在則打開
  • IPC_EXCL :若存在則創建失敗
  • 0 :獲取已經存在的信號量集
//create sem
semid=semget(key,1,IPC_CREAT|IPC_EXCL|0664);
if(-1==semid)
    perror("semid"),exit(-1);

semctl()

//主要用於對指定的信號量集/信號量執行指定的操作,成功返回0,失敗返回-1設errno
int semctl(int semid, int semnum, int cmd, ...);

semid: 信號量集的編號(哪個信號量集)
semnum: 信號量集的下標(這個信號量集里的哪個信號量)
cmd:具體的操作命令

  • IPC_STAT 將內核中與semid相關的信息拷貝到arg.buf指向的結構體中
  • IPC_SET將buf指向的semid_ds結構體的部分內容寫入到內核中的相關數據結構中,同時更新sem_ctime成員
  • IPC_RMID 立即銷毀指定的信號量集,調用的進程的的effective UID必須和信號量集的創建者或所有者相匹配,或者這個進程有足夠的特權級別,此時第四個參數會被忽略
  • IPC_INFO(Linux-specific)返回系統對信號量集的限制到__buf指向的結構體seminfo中
//_GNU_SOURCE
struct  seminfo {
    int     semmap;     /* Number of entries in semaphore map; unused within kernel */
    int     semmni;     /* Maximum number of semaphore sets */
    int     semmns;     /* Maximum number of semaphores in all semaphore sets */
    int     semmnu;     /* System-wide maximum number of undo structures; unused within kernel */
    int     semmsl;     /* Maximum number of semaphores in a set */
    int     semopm;     /* Maximum number of operations for  semop(2) */
    int     semume;     /* Maximum number of undo entries per process; unused within kernel */
    int     semusz;     /* Size of struct sem_undo */
        int     semvmx;     /* Maximum semaphore value */
    int     semaem;     /* Max. value that can be recorded for semaphore adjustment (SEM_UNDO) */
};

//semmsl, semmns, semopm, semmni可以通過/proc/sys/kernel/sem來設置
  • SEM_INFO (Linux-specific)返回和IPC_INFO一樣的信息,除了以下方面:semusz成員返回當前系統中存在的信號量集的數目,semaem返回系統中所有信號量集中的信號量總數
  • SEM_STAT(Linux-specific)返回semid_ds結構,類似與IPC_STAT
  • GETALL 返回所有信號量的semval到arg.array中,忽略semnum
  • GETNCNT 返回信號量集第semnum個信號量的semcnt值
  • GETPID 返回信號量集第semnum個信號量的sempid值
  • GETVAL 返回信號量集第semnum個信號量的semval值
  • GETZCNT 返回信號量集第semnum個信號量的semzcnt值
  • SETALL 使用arg.array設置信號量集里的所有的信號量的semval值,同時更新信號量集的semid_ds結構體的sem_ctime成員的值
  • SETVAL返回信號量集第semnum個信號量的semval的值到arg.val中,同時更新信號量集的semid_ds結構體的sem_ctime成員的值

the fourth argument:

union semun {
    int              val;   /* Value for SETVAL */
    struct semid_ds* buf;   /* Buffer for IPC_STAT, IPC_SET */
    unsigned short* array;  /* Array for GETALL, SETALL */
    struct seminfo* __buf;  /* Buffer for IPC_INFO(Linux-specific) */
};

//<sys/sem.h>
struct semid_ds {
    struct ipc_perm sem_perm;   /* Ownership and permissions */
    time_t          sem_otime;  /* Last semop time */
    time_t          sem_ctime;  /* Last change time */
    unsigned short  sem_nsems;  /* No. of semaphores in set */
};

//<sys/ipc.h>
struct ipc_perm {
    key_t           __key;  /* Key supplied to semget(2) */
    uid_t           uid;    /* Effective UID of owner */
    gid_t           gid;    /* Effective GID of owner */
    uid_t           cuid;   /* Effective UID of creator */
    gid_t           cgid;   /* Effective GID of creator */
    unsigned short  mode;   /* Permissions */
    unsigned short  __seq;  /* Sequence number */
};
int res=semctl(semid,0,SETVAL,5);
if(-1==res)
    perror("semctl"),exit(-1);
int res=semctl(semid,0,IPC_RMID);
if(-1==res)
    perror("semctl"),exit(-1);

semop():

//操作指定的信號量集,成功返回0,失敗返回-1設errno
int semop(int semid, struct sembuf *sops, unsigned nsops);

semid:信號集的ID(returned by semget())
sops:結構體指針, 既可以指向結構體變數, 也可以指向結構體數組信號量集本質上是若幹個信號量的集合, 可以實現對信號量的批處理

struct sembuf{
    unsigned short  sem_num;    //信號量集的下標
    short           sem_op;     //正數表示增加, 0表示不變, 負數表示減小
    short           sem_flg;    //操作標誌,預設給0
}

nsops:結構體指針指向的元素個數, 也就是數組的大小

例子

Sys V IPC sem
#include<unistd.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/sem.h>
#include<signal.h>
#include<stdio.h>
#include<stdlib.h>
int main(){
    //get key
    key_t key=ftok(".",200);
    if(-1==key)
        perror("ftok"),exit(-1);
    printf("key=%d\n",key);
    //create sem
    int semid=semget(key,0,0);
    if(-1==semid)
        perror("semget"),exit(-1);
    printf("semid=%d\n",semid);
    //creat 10 children to take the shared resource
    int i=0;
    for(i=0;i<10;i++){      //創建10個進程, 當然,需要只給parent或child單獨fork(), 否則就是2^10個進程
        pid_t pid=fork();
        if(-1==pid)
            perror("fork"),exit(-1);
        if(0==pid){

            struct sembuf buf;      //準備占用資源, sem_op-1
            buf.sem_num=0;      //信號量集下標
            buf.sem_op=-1;      //信號量-1
            buf.sem_flg=0;      //操作標誌
            int res=semop(semid,&buf,1/*結構體變數的個數*/);
            if(-1==res)
                perror("semop"),exit(-1);

            sleep(20);          //模擬正在占用共用資源

            buf.sem_op=1;       //占用完了, sem_op+1
            res=semop(semid,&buf,1);
            if(-1==res)
                perror("semop"),exit(-1);

            exit(0);                //終止子進程, 自然也就跳出了迴圈,防止再fork()
        //  break;
        }
    }   
    return 0;
}
//出現搶占的效果, 還沒有全部釋放完畢的時候就有進程搶到了已經釋放的進程

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 遇到這個問題 網上找到的解決辦法: 方法一:就是上面說的通過計算出來ListView或者GridView中的子列高度和 進行顯示:public void setListViewHeightBasedOnChildren(ListView listView) { ListAdapter listAda ...
  • self.mManager = [[CMMotionManager alloc]init]; self.mManager.deviceMotionUpdateInterval = 0.5; if (self.mManager.gyroAvailable) { [self.mManager start ...
  • 在前面的文章中,已經實現了“設置中心”第一欄的功能以及佈局 本文地址:http://www.cnblogs.com/wuyudong/p/5936016.html,轉載請註明出處。 自定義屬性聲明 接下來實現其他欄的佈局和功能,由於它們之間的功能和佈局類似,只是屬性名稱不同。所以本文在自定義控制項的基 ...
  • TCP : Transmission Control Protocol,傳輸控制協議,類似於打電話 UDP : User Datagram Protocol,用戶數據報協議,類似於寫信 IP : Internet Protocol互聯網協議,是上述兩種協議的底層協議 IP地址(IP Address) ...
  • 模型: 1. 初始化並打開有名信號量:sem_open() 創建/獲得無名信號量:sem_init() 操作信號量:sem_wait()/sem_trywait()/sem_timedwait()/sem_post()/sem_getvalue() 退出有名信號量:sem_close() 銷毀有名信 ...
  • 模型: 1. 創建/獲取消息隊列fd :mq_open() 設置/獲取消息隊列屬性 :mq_get() 發送/接收消息 :mq_send()/mq_receive() 脫接消息隊列 :mq_close() 刪除消息隊列 :mq_unlink() 頭文件 POSIX mq VS Sys V mq的優勢 ...
  • 模型 1. 創建/獲取共用記憶體fd :shm_open() 2. 創建者調整文件大小 :ftruncate() 3. 映射fd到記憶體 :mmap() 4. 去映射fd :munmap() 5. 刪除共用記憶體 :shm_unlink() 頭文件 shm_open oflag Access Mode: ...
  • DNS簡單來說就是進行功能變數名稱和IP的轉換,那該如何轉換呢?既然要轉換,肯定有轉換表,那表應該存 哪個伺服器上,怎樣去請求功能變數名稱伺服器來進行轉換,所以,這個轉換的過程都是什麼。而面試的時 經常會有這道題:當在瀏覽器輸入網址按下回車之後,到瀏覽器回顯網頁,詳細描述一下中間發生了神馬? 一般來說,在windo ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...