如何實(shí)現(xiàn)c#多線程之間的排他鎖

這篇文章主要介紹了如何實(shí)現(xiàn)c#多線程之間的排他鎖，具有一定借鑒價(jià)值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

我們很多時(shí)候會(huì)碰到這樣的問題，使用多線程刷一個(gè)表的數(shù)據(jù)時(shí)需要多個(gè)線程不能重復(fù)提取數(shù)據(jù)，那么這個(gè)時(shí)候就需要使用到線程的排他鎖了。

在c#里面其實(shí)很簡(jiǎn)單，下面先來看一個(gè)簡(jiǎn)單的小例子

Thread pingTask = new Thread(new ThreadStart(delegate
           {
               //從數(shù)據(jù)庫獲取1000條數(shù)
               var list = getdata();
           }));
 
           //啟動(dòng)線程
           pingTask.Start();

如果這個(gè)時(shí)候我們開啟多個(gè)線程

代碼如下

for (int i = 0; i < 100; i++)
            {
                Thread pingTask = new Thread(new ThreadStart(delegate
               {
                //從數(shù)據(jù)庫獲取1000條數(shù)
                var list = getdata();
               }));
 
                //啟動(dòng)線程
                pingTask.Start(); 
            }

那么這100個(gè)線程獲取的數(shù)據(jù)可能大部分是重復(fù)的
怎么樣解決這個(gè)問題呢，兩種寫法

第一種寫法使用this

private List<company> getdata()
        {
            lock (this)
            {
//提取數(shù)據(jù)
 
                return list;
            }
        }

這種寫法當(dāng)線程執(zhí)行到這一步時(shí)所有線程都會(huì)停止執(zhí)行，等待執(zhí)行完成

我們?cè)賮砜吹诙N

object obj=new object()
       private List<company> getdata()
       {
           lock (obj)
           {
               List<ckb_com> list = ckbbll.FindList($" com_id >={index} and com_id<{index + pagesize}");
               index = index + pagesize;
 
               return list;
           }
       }

這種寫法只會(huì)鎖死這個(gè)方法，
同時(shí)只會(huì)有一個(gè)線程能執(zhí)行這個(gè)方法
大家可以根據(jù)自己的需求來使用

感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“如何實(shí)現(xiàn)c#多線程之間的排他鎖”這篇文章對(duì)大家有幫助，同時(shí)也希望大家多多支持億速云，關(guān)注億速云行業(yè)資訊頻道，更多相關(guān)知識(shí)等著你來學(xué)習(xí)!