<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    so true

    心懷未來,開創未來!
    隨筆 - 160, 文章 - 0, 評論 - 40, 引用 - 0
    數據加載中……

    read-write lock

    (一)當前被讀鎖占著
        1。如果讀優先(默認是PTHREAD_RWLOCK_PREFER_READER_NP,即讀優先),那么等著的讀請求可以快速拿到鎖,寫一直被餓著(直到沒有任何等待獲取讀鎖的情況下,寫才能拿到寫鎖);
        2。如果寫優先,那么讀和寫都等著,一但前面的讀釋放了鎖,寫立刻就會優先讀來拿到鎖;
    (二)當前被寫鎖占著
        不論誰優先,都需要把所有等著的寫都服務完,才會給讀機會,所以寫多讀少的情況下,就應該用互斥鎖了;

    測試程序:
    #include <iostream>
    #include <string>
    #include <fstream>
    #include <sstream>
    #include <stdint.h>
    #include <pthread.h>
    #include <vector>
    #include <map>
    #include <set>
    using namespace std;
    long g_idx = 0;
    class ThreadRwLock {
    private:
        pthread_rwlock_t m_rw_mutex;
    public:
        ThreadRwLock() {
            pthread_rwlockattr_t attr;
            // 設置寫優先
            pthread_rwlockattr_init(&attr);
            //pthread_rwlockattr_setkind_np(&attr, PTHREAD_RWLOCK_PREFER_WRITER_NONRECURSIVE_NP);
            pthread_rwlock_init(&m_rw_mutex, &attr);
        }
        ~ThreadRwLock() {
            pthread_rwlock_destroy(&m_rw_mutex);
        }
        void rdlock() {
            pthread_rwlock_rdlock(&m_rw_mutex);
        }
        void wrlock() {
            pthread_rwlock_wrlock(&m_rw_mutex);
        }
        int tryrdlock() {
            return pthread_rwlock_tryrdlock(&m_rw_mutex);
        }
        int trywrlock() {
            return pthread_rwlock_trywrlock(&m_rw_mutex);
        }
        void unlock() {
            pthread_rwlock_unlock(&m_rw_mutex);
        }
    };
    ThreadRwLock g_lock;
    void* thread_routine(void* arg) {
        long is_write = (long)arg;
        if (is_write) {
            printf("%lu wait write lock\n", pthread_self()); fflush(stdout);
            g_lock.wrlock();
            long idx = __sync_add_and_fetch(&g_idx, 1);
            printf("%lu get write lock, %ld\n", pthread_self(), idx); fflush(stdout);
            sleep(5);
            g_lock.unlock();
        } else {
            printf("%lu wait read lock\n", pthread_self()); fflush(stdout);
            g_lock.rdlock();
            long idx = __sync_add_and_fetch(&g_idx, 1);
            printf("%lu get read lock, %ld\n", pthread_self(), idx); fflush(stdout);
            sleep(5);
            g_lock.unlock();
        }
        return NULL;
    }
    int main(int argc, char* argv[]) {
        pthread_t tid = 0;
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        getchar(); //讓程序暫停,等待鍵盤敲入一個字節后,接著走
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        sleep(2); //確保寫鎖被優先拿到
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)1);
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        pthread_create(&tid, NULL, thread_routine, (void*)0);
        getchar();
        return 0;
    }

    posted on 2018-05-14 12:07 so true 閱讀(204) 評論(0)  編輯  收藏 所屬分類: C&C++Linux

    主站蜘蛛池模板: 亚洲无圣光一区二区| jlzzjlzz亚洲乱熟在线播放| 亚洲男人第一av网站| 国产99视频精品免费视频76| 成人免费福利电影| 亚洲天堂2017无码中文| 亚洲国产精品综合久久20| 中国人xxxxx69免费视频| 免费看美女让人桶尿口| 亚洲区小说区图片区QVOD| 亚洲人成未满十八禁网站| 美女被cao免费看在线看网站| 亚洲视频一区二区在线观看| 一级特黄a免费大片| 国产精品成人观看视频免费| 亚洲国产精品一区二区第四页| 看免费毛片天天看| 亚洲人成网站色在线入口| 成全视成人免费观看在线看| 亚洲男同帅GAY片在线观看| 亚在线观看免费视频入口| 亚洲国产一区视频| 搡女人免费免费视频观看| 久久精品亚洲中文字幕无码网站| 99久久久国产精品免费牛牛四川| 亚洲福利视频网址| 免费h视频在线观看| 国产精品亚洲二区在线观看| 中文字幕无码毛片免费看| 亚洲av永久无码精品漫画| 九九精品免费视频| 在线亚洲精品视频| 国产精品亚洲а∨无码播放| 亚洲免费观看在线视频| 无码欧精品亚洲日韩一区| 日批视频网址免费观看| 亚洲国产精品成人综合色在线婷婷| 免费毛片在线播放| 国产午夜无码片免费| 亚洲人成在线免费观看| 免费在线观看一级毛片|