C#多线程之线程锁

目录
  • 一、Mutex类
  • 二、Mutex的用途
  • 三、Semaphore信号量
    • 1、简介
    • 2、初始化
    • 3、WaitOne()和Release()
  • 四、Monitor类
    • 典型的生产者与消费者实例
  • 五、Lock
  • 六、InterLocked(相当于lock,对整数)
    • 1、Interlocked类主要方法
    • 2、实例

一、Mutex类

“mutex”是术语“互相排斥(mutually exclusive)”的简写形式,也就是互斥量。互斥量跟临界区中提到的Monitor很相似,只有拥有互斥对象的线程才具有访问资源的权限,由于互斥对象只有一个,因此就决定了任何情况下此共享资源都不会同时被多个线程所访问。当前占据资源的线程在任务处理完后应将拥有的互斥对象交出,以便其他线程在获得后得以访问资源。互斥量比临界区复杂,因为使用互斥不仅仅能够在同一应用程序不同线程中实现资源的安全共享,而且可以在不同应用程序的线程之间实现对资源的安全共享。.Net中mutex由Mutex类来表示。

二、Mutex的用途

Mutex并不适合于有相互消息通知的同步;另一方面局部Mutex应该被Monitor/lock所取代;而跨应用程序的、相互消息通知的同步由EventWaiteHandle/AutoResetEvent/ManualResetEvent承担更合适。所以,Mutex在.net中应用的场景似乎不多。不过,Mutex有个最常见的用途:用于控制一个应用程序只能有一个实例运行。系统依靠这个name属性来标识唯一的Mutex。

private static Mutex mutex = null;  //设为Static成员,是为了在整个程序生命周期内持有Mutex

static void Main()
{
    bool firstInstance;

    mutex = new Mutex(true, @"Global\MutexSampleApp", out firstInstance);
    try
    {
        if (firstInstance)
        {
            Console.WriteLine("我们是第一个实例!");
        }
        else
        {
            Console.WriteLine("警告,已有实例运行!");
            return;
        }
    }
    finally
    {
        //只有第一个实例获得控制权,因此只有在这种情况下才需要ReleaseMutex,否则会引发异常。
        if (firstInstance)
        {
            mutex.ReleaseMutex();
        }
        mutex.Close();
        mutex = null;
    }
}

三、Semaphore信号量

1、简介

Semaphore是操作系统中用于控制线程同步互斥的信号量。在编写多线程的程序时,可以使用Semaphore信号量来协调多线程并行,使各个线程能够合理地共享资源,保证程序正确运行。

2、初始化

初始化Semaphore可当做开启了一个线程池,initialCount代表剩余空位,maximumCount代表最大容量。示例如下,当前空位为0,最大容量为1:

Semaphore sem = new Semaphore(0, 1);

3、WaitOne()和Release()

Semaphore常用的方法有两个WaitOne()和Release()。

使用WaitOne()方法相当于等待出现退出的线程,而使用Release()方法为让一个线程退出。

假设initialCount和maximumCount都为5,开始的时候线程池有5个空位置,且总共只有5个位置,当需要并行的线程数量超过5个时,首先使用WaitOne()方法等待,发现有空位就依次进去,每进去一个空位减1,直到进去5个线程之后,空位(initialCount)为0,这时候后面的线程就一直等待,直到有线程调用了Release()方法,主动退出线程池,空位加1,在等待的线程才能继续进入线程池。

下面的代码示例创建一个信号量, 其最大计数为 3, 初始计数为零。 该示例启动五个线程, 这会阻止等待信号量。 主线程使用Release(Int32)方法重载将信号量计数增加到其最大值, 从而允许三个线程进入信号量。 每个线程使用Thread.Sleep方法等待一秒, 以模拟工作, 然后Release()调用方法重载以释放信号量。 每次释放信号灯时, 都将显示以前的信号量计数。 控制台消息跟踪信号量使用。 每个线程的模拟工作时间间隔略有增加, 使输出更易于读取。

private static Semaphore _pool;

private static int _padding;

public static void Main()
{
    _pool = new Semaphore(0, 3);

    for (int i = 1; i <= 5; i++)//创建并启动五个线程。
    {
        Thread t = new Thread(new ParameterizedThreadStart(Worker));

        t.Start(i);// 启动线程,传递数字。
    }

    Thread.Sleep(500);

    Console.WriteLine("Main thread calls Release(3).");
    _pool.Release(3);//调用Release(3)会使信号量计数回其最大值,并允许等待的线程进入信号量,一次最多三个。

    Console.WriteLine("Main thread exits.");
}

private static void Worker(object num)
{
    Console.WriteLine("Thread {0} begins " + "and waits for the semaphore.", num);
    _pool.WaitOne();

    //填充间隔,使输出更加有序。
    int padding = Interlocked.Add(ref _padding, 100);

    Console.WriteLine("Thread {0} enters the semaphore.", num);

    Thread.Sleep(1000 + padding);

    Console.WriteLine("Thread {0} releases the semaphore.", num);
    Console.WriteLine("Thread {0} previous semaphore count: {1}", num, _pool.Release());
}

四、Monitor类

当多个线程公用一个对象时,也会出现和公用代码类似的问题,这就需要用到 System.Threading 中的 Monitor 类,我们可以称之为监视器,Monitor 提供了使线程共享资源的方案。
Monitor 类可以锁定一个对象,一个线程只有得到这把锁才可以对该对象进行操作。 对象锁机制保证了在可能引起混乱的情况下,一个时刻只有一个线程可以访问这个对象。Monitor 必须和一个具体的对象相关联。

下面代码说明了使用 Monitor 锁定一个对象的情形:

// 表示对象的先进先出集合
Queue oQueue = new Queue();
try
{
    // 现在 oQueue 对象只能被当前线程操纵了
    Monitor.Enter(oQueue);

    // do something......
}
catch
{

}
finally
{
    // 释放锁
    Monitor.Exit(oQueue);
}

如上所示, 当一个线程调用 Monitor.Enter() 方法锁定一个对象时,这个对象就归它所有了,其它线程想要访问这个对象,只有等待它使用Monitor.Exit() 方法释放锁。为了保证线程最终都能释放锁,你可以把 Monitor.Exit() 方法写在 try-catch-finally 结构中的 finally 代码块里。(lock 关键字就是这个步骤的语法糖

任何一个被 Monitor 锁定的对象,内存中都保存着与它相关的一些信息:

  • 现在持有锁的线程的引用
  • 一个预备队列,队列中保存了已经准备好获取锁的线程
  • 一个等待队列,队列中保存着当前正在等待这个对象状态改变的队列的引用

当拥有对象锁的线程准备释放锁时,它使用 Monitor.Pulse() 方法通知等待队列中的第一个线程,于是该线程被转移到预备队列中,当对象锁被释放时,在预备队列中的线程可以立即获得对象锁。

典型的生产者与消费者实例

下面是一个展示如何使用 lock 关键字和 Monitor 类来实现线程的同步和通讯的例子。在本例中,生产者线程和消费者线程是交替进行的,生产者写入一个数,消费者立即读取并且显示(注释中介绍了该程序的精要所在)。

/// <summary>
/// 测试类
/// </summary>
public class MonitorSample
{
    public static void Main(String[] args)
    {
        // 一个标志位,如果是 0 表示程序没有出错,如果是 1 表明有错误发生
        int result = 0;

        // 下面使用 cell 初始化 CellProd 和 CellCons 两个类,生产和消费次数均为 20 次
        Cell cell = new Cell();
        CellProd prod = new CellProd(cell, 20);
        CellCons cons = new CellCons(cell, 20);
        Thread producer = new Thread(new ThreadStart(prod.ThreadRun));
        Thread consumer = new Thread(new ThreadStart(cons.ThreadRun));

        // 生产者线程和消费者线程都已经被创建,但是没有开始执行
        try
        {
            producer.Start();
            consumer.Start();
            producer.Join();
            consumer.Join();//等待这两个线程结束才往下执行
            Console.ReadLine();
        }
        catch (ThreadStateException e)
        {
            // 当线程因为所处状态的原因而不能执行被请求的操作
            Console.WriteLine(e);
            result = 1;
        }
        catch (ThreadInterruptedException e)
        {
            // 当线程在等待状态的时候中止
            Console.WriteLine(e);
            result = 1;
        }
        // 尽管 Main() 函数没有返回值,但下面这条语句可以向父进程返回执行结果
        Environment.ExitCode = result;
    }
}

/// <summary>
/// 生产者
/// </summary>
public class CellProd
{
    /// <summary>
    /// 被操作的 Cell 对象
    /// </summary>
    Cell cell;

    /// <summary>
    /// 生产者生产次数,初始化为 1
    /// </summary>
    int quantity = 1;

    public CellProd(Cell box, int request)
    {
        cell = box;
        quantity = request;
    }

    public void ThreadRun()
    {
        for (int looper = 1; looper <= quantity; looper++)
        {
            // 生产者向操作对象写入信息
            cell.WriteToCell(looper);
        }
    }
}

/// <summary>
/// 消费者
/// </summary>
public class CellCons
{
    Cell cell;
    int quantity = 1;

    public CellCons(Cell box, int request)
    {
        cell = box;
        quantity = request;
    }

    public void ThreadRun()
    {
        int valReturned;
        for (int looper = 1; looper <= quantity; looper++)
        {
            valReturned = cell.ReadFromCell(); // 消费者从操作对象中读取信息
        }
    }
}

/// <summary>
/// 被操作的对象
/// </summary>
public class Cell
{
    /// <summary>
    /// Cell 对象里的内容
    /// </summary>
    int cellContents;

    /// <summary>
    /// 状态标志: 为 true 时可以读取,为 false 则正在写入
    /// </summary>
    bool readerFlag = false;

    public int ReadFromCell()
    {
        lock (this)
        {
            if (!readerFlag)
            {
                try
                {
                    // 等待 WriteToCell 方法中调用 Monitor.Pulse()方法
                    Monitor.Wait(this);
                }
                catch (SynchronizationLockException e)
                {
                    Console.WriteLine(e);
                }
                catch (ThreadInterruptedException e)
                {
                    Console.WriteLine(e);
                }
            }

            // 开始消费行为
            Console.WriteLine("Consume: {0}", cellContents);
            Console.WriteLine();

            // 重置 readerFlag 标志,表示消费行为已经完成
            readerFlag = false;

            Monitor.Pulse(this);// 通知 WriteToCell()方法(该方法在另外一个线程中执行,等待中)
        }
        return cellContents;
    }

    public void WriteToCell(int n)
    {
        lock (this)
        {
            if (readerFlag)
            {
                try
                {
                    Monitor.Wait(this);
                }
                catch (SynchronizationLockException e)
                {
                    // 当同步方法(指Monitor类除Enter之外的方法)在非同步的代码区被调用
                    Console.WriteLine(e);
                }
                catch (ThreadInterruptedException e)
                {
                    // 当线程在等待状态的时候中止
                    Console.WriteLine(e);
                }
            }
            cellContents = n;
            Console.WriteLine("Produce: {0}", cellContents);
            readerFlag = true;
            Monitor.Pulse(this); // 通知另外一个线程中正在等待的 ReadFromCell() 方法
        }
    }
}

五、Lock

C# 提供了一个关键字 lock,它可以把一段代码定义为互斥段(critical section),互斥段在一个时刻内只允许一个线程进入执行,而其他线程必须等待。

在C#中,关键字 lock 的定义:

lock(expression) 
 {statement_block}

expression 代表你希望跟踪的对象,通常是对象引用。如果你想保护一个类的实例,你可以使用 this;如果你想保护一个静态变量(如互斥代码段在一个静态方法内部),一般使用锁定一个私有的static 成员变量就可以了。而 statement_block 就是互斥段的代码,这段代码在一个时刻内只可能被一个线程执行。

NET在一些集合类中(比如ArrayList,HashTable,Queue,Stack)已经提供了一个供lock使用的对象SyncRoot,用Reflector工具查看了SyncRoot属性的代码,在Array中,该属性只有一句话:return this,这样和lock array的当前实例是一样的。

Lock 语法简单易用。其本质是针对 Monitor.Enter() 和 Monitor.Exit() 的封装,是一个语法糖!

static internal Thread[] threads = new Thread[10];
public static void Main()
{
    Account acc = new Account(100);
    for (int i = 0; i < 10; i++)
    {
        Thread t = new Thread(new ThreadStart(acc.DoTransactions));
        threads[i] = t;
        threads[i].Name = i.ToString();
        threads[i].Start(); //10个线程同时启动
    }
}

internal class Account
{
    int balance;internal Account(int initial)
    {
        balance = initial;
    }

    internal void DoTransactions()
    {
        for (int i = 0; i < 100; i++)
        {
            int amount = new Random().Next(-100, 100);

            lock (this)
            {
                Console.WriteLine("当前线程:" + Thread.CurrentThread.Name + " 余额:" + balance.ToString() + " 数量:" + amount);
                if (balance >= amount)
                {
                    Thread.Sleep(5);
                    balance = balance - amount;
                }
                else
                {
                    Console.WriteLine("当前线程:" + Thread.CurrentThread.Name + " 不能交易,余额不足:" + balance.ToString());
                    return;
                }
            }
        }
    }
}

六、InterLocked(相当于lock,对整数)

在C#中,赋值和简单的数字运算都不是原子型操作。 在多线程环境下,我们可以通过使用System.Threading.Interlocked类来实现原子型操作当个数据,使用它比使用Monitor类跟简单。

使用.NET提供的Interlocked类可以对一些数据进行原子操作,看起来似乎跟lock锁一样,但它并不是lock锁,它的原子操作是基于CPU本身的,非阻塞的,所以要比lock的效率高。

1、Interlocked类主要方法

  • Read() 安全读取数值,相等于int a=b
  • Add() 安全相加一个数值,相当于 a = a + 3
  • Increment() 安全递加1,相当于 i++。返回递增后的值。
  • Decrement()安全递减1,相当于 i--Exchange() 安全交换数据,返回递减后的值。
  • CompareExchange() 安全比较两个值是不是相等。如果相等,将第三个值与其中一个值交换。

2、实例

例一:

void Main()
{
    TestIncrementUnSafe();
    TestIncrementSafe();
}

private int value1 = 0;
public void TestIncrementUnSafe()
{
    for (int i = 0; i < 5; i++)
    {
        Thread t = new Thread(IncrementValue1);
        t.Name = "t1 " + i;
        t.Start();
    }
    Thread.Sleep(2000);
    //value maybe 500000
    Console.WriteLine("value1 = " + value1);
}
private void IncrementValue1()
{
    for (int i = 0; i < 1000000; i++)
    {
        value1++;
    }
}

private int value2 = 0;
public void TestIncrementSafe()
{
    for (int i = 0; i < 5; i++)
    {
        Thread t = new Thread(IncrementValue2);
        t.Name = "t2 " + i;
        t.Start();
    }
    Thread.Sleep(2000);
    //value should be 500000
    Console.WriteLine("value2 = " + value2);
}

private void IncrementValue2()
{
    for (int i = 0; i < 1000000; i++)
    {
        Interlocked.Increment(ref value2);
    }
}

运行结果

value1 = 4612592
value2 = 5000000

例二、

void Main()
{
    TestExchangeSafe();
    TestCompareExchangeSafe();
}
private int value3 = 0;
public void TestExchangeSafe()
{
    for (int i = 0; i < 5; i++)
    {
        Thread t = new Thread(ExchangeValue3);
        t.Name = "t2 " + i;
        t.Start();
    }
    Thread.Sleep(2000);
    //value should be 83
    Console.WriteLine("value3 = " + value3);
}
private void ExchangeValue3()
{
    Interlocked.Exchange(ref value3, 83);
}

private int value4 = 0;
public void TestCompareExchangeSafe()
{
    for (int i = 0; i < 5; i++)
    {
        Thread t = new Thread(ExchangeValue3);
        t.Name = "t2 " + i;
        t.Start();
    }
    Thread.Sleep(2000);
    //value should be 99 or 0
    Console.WriteLine("value4 = " + value4);
}
private void ExchangeValue4()
{
    //if value4=0, set value4=99
    Interlocked.CompareExchange(ref value4, 99, 0);
}

运行结果:

value3 = 83
value4 = 0

到此这篇关于C#多线程之线程锁的文章就介绍到这了。希望对大家的学习有所帮助,也希望大家多多支持我们。

时间: 2022-05-12

C#多线程系列之读写锁

本篇的内容主要是介绍 ReaderWriterLockSlim 类,来实现多线程下的读写分离. ReaderWriterLockSlim ReaderWriterLock 类:定义支持单个写线程和多个读线程的锁. ReaderWriterLockSlim 类:表示用于管理资源访问的锁定状态,可实现多线程读取或进行独占式写入访问. 两者的 API 十分接近,而且 ReaderWriterLockSlim 相对 ReaderWriterLock 来说 更加安全.因此本文主要讲解 ReaderWrit

C#多线程编程中的锁系统(二)

上章主要讲排他锁的直接使用方式.但实际当中全部都用锁又太浪费了,或者排他锁粒度太大了. 这一次我们说说升级锁和原子操作. 目录 1:volatile 2:  Interlocked 3:ReaderWriterLockSlim 4:总结 一:volatile 简单来说: volatile关键字是告诉c#编译器和JIT编译器,不对volatile标记的字段做任何的缓存.确保字段读写都是原子操作,最新值. 这不就是锁吗?   其这货它根本不是锁, 它的原子操作是基于CPU本身的,非阻塞的. 因为32

C#多线程编程中的锁系统(四):自旋锁

目录 一:基础 二:自旋锁示例 三:SpinLock 四:继续SpinLock 五:总结 一:基础 内核锁:基于内核对象构造的锁机制,就是通常说的内核构造模式.用户模式构造和内核模式构造 优点:cpu利用最大化.它发现资源被锁住,请求就排队等候.线程切换到别处干活,直到接受到可用信号,线程再切回来继续处理请求. 缺点:托管代码->用户模式代码->内核代码损耗.线程上下文切换损耗. 在锁的时间比较短时,系统频繁忙于休眠.切换,是个很大的性能损耗. 自旋锁:原子操作+自循环.通常说的用户构造模式.

C#使用读写锁三行代码简单解决多线程并发的问题

在开发程序的过程中,难免少不了写入错误日志这个关键功能.实现这个功能,可以选择使用第三方日志插件,也可以选择使用数据库,还可以自己写个简单的方法把错误信息记录到日志文件. 选择最后一种方法实现的时候,若对文件操作与线程同步不熟悉,问题就有可能出现了,因为同一个文件并不允许多个线程同时写入,否则会提示"文件正在由另一进程使用,因此该进程无法访问此文件". 这是文件的并发写入问题,就需要用到线程同步.而微软也给线程同步提供了一些相关的类可以达到这样的目的,本文使用到的 System.Thr

C#使用读写锁解决多线程并发问题

一.简介 在开发程序的过程中,难免少不了写入错误日志这个关键功能.实现这个功能,可以选择使用第三方日志插件,也可以选择使用数据库,还可以自己写个简单的方法把错误信息记录到日志文件.现在我们来讲下最后一种方法: 在选择最后一种方法实现的时候,若对文件操作与线程同步不熟悉,问题就有可能出现了,因为同一个文件并不允许多个线程同时写入,否则会提示“文件正在由另一进程使用,因此该进程无法访问此文件”.这是文件的并发写入问题,就需要用到线程同步.而微软也给线程同步提供了一些相关的类可以达到这样的目的,本文使

C#笔试题之同线程Lock语句递归不会死锁

前几天在网上闲逛,无意中看到有这么一道题及其答案,如下: 根据线程安全的相关知识,分析以下代码,当调用test方法时i>10时是否会引起死锁?并简要说明理由. public void test(int i) { lock(this) { if (i > 10) { i--; test(i); } } } 答:不会发生死锁,(但有一点int是按值传递的,所以每次改变的都只是一个副本,因此不会出现死锁.但如果把int换做一个object,那么死锁会发生) 当我看到这道题时,我心里只有两个答案,1.

C#多线程中如何运用互斥锁Mutex

互斥锁(Mutex) 互斥锁是一个互斥的同步对象,意味着同一时间有且仅有一个线程可以获取它. 互斥锁可适用于一个共享资源每次只能被一个线程访问的情况 函数: //创建一个处于未获取状态的互斥锁 Public Mutex(): //如果owned为true,互斥锁的初始状态就是被主线程所获取,否则处于未获取状态 Public Mutex(bool owned): 如果要获取一个互斥锁.应调用互斥锁上的WaitOne()方法,该方法继承于Thread.WaitHandle类 它处于等到状态直至所调用

C#在复杂多线程环境下使用读写锁同步写入文件

代码一: class Program { static int LogCount = 1000; static int SumLogCount = 0; static int WritedCount = 0; static int FailedCount = 0; static void Main(string[] args) { //往线程池里添加一个任务,迭代写入N个日志 SumLogCount += LogCount; ThreadPool.QueueUserWorkItem((obj)

C#多线程死锁介绍与案例代码

一.死锁简介 在多道程序设计环境下,多个进程可能竞争一定数量的资源,.一个进程申请资源,如果资源不可用,那么进程进入等待状态.如果所申请的资源被其他等待进程占有,那么该等待的进程有可能无法改变状态,这种情况下称之为死锁. 二.死锁条件 死锁的四个条件: 1.非抢占:资源不能被抢占2.互斥:至少有一个资源必须处在非共享模式,即一次只能有一个进程使用,如果另一进程申请该资源,那么申请进程必须延迟直到该资源释放为止.3.占有并等待:一个进程必须占有至少一个资源,并等待另一个资源,而该资源为其他进程所占

C#多线程系列之多线程锁lock和Monitor

目录 1,Lock lock 原型 lock 编写实例 2,Monitor 怎么用呢 解释一下 示例 设置获取锁的时效 1,Lock lock 用于读一个引用类型进行加锁,同一时刻内只有一个线程能够访问此对象.lock 是语法糖,是通过 Monitor 来实现的. Lock 锁定的对象,应该是静态的引用类型(字符串除外). 实际上字符串也可以作为锁的对象使用,只是由于字符串对象的特殊性,可能会造成不同位置的不同线程冲突.如果你能保证字符串的唯一性,例如 Guid 生成的字符串,也是可以作为锁的对

C#多线程编程中的锁系统基本用法

平常在多线程开发中,总避免不了线程同步.本篇就对net多线程中的锁系统做个简单描述. 目录 一:lock.Monitor      1:基础.      2: 作用域.      3:字符串锁.      4:monitor使用 二:mutex 三:Semaphore 四:总结 一:lock.Monitor 1:基础 Lock是Monitor语法糖简化写法.Lock在IL会生成Monitor. 复制代码 代码如下: //======Example 1=====             strin

C#多线程中的互斥锁Mutex

一.简介 Mutex的突出特点是可以跨应用程序域边界对资源进行独占访问,即可以用于同步不同进程中的线程,这种功能当然这是以牺牲更多的系统资源为代价的. 主要常用的两个方法: public virtual bool WaitOne() 阻止当前线程,直到当前 System.Threading.WaitHandle 收到信号获取互斥锁. public void ReleaseMutex() 释放 System.Threading.Mutex 一次. 二.代码 案例一: class Program {

C#多线程编程中的锁系统(三)

本章主要说下基于内核模式构造的线程同步方式,事件,信号量. 目录 一:理论 二:WaitHandle 三:AutoResetEvent 四:ManualResetEvent 五:总结 一:理论 我们晓得线程同步可分为,用户模式构造和内核模式构造. 内核模式构造:是由windows系统本身使用,内核对象进行调度协助的.内核对象是系统地址空间中的一个内存块,由系统创建维护. 内核对象为内核所拥有,而不为进程所拥有,所以不同进程可以访问同一个内核对象, 如进程,线程,作业,事件,文件,信号量,互斥量等

c#多线程之间的排他锁的实现

我们很多时候会碰到这样的问题,使用多线程刷一个表的数据时需要多个线程不能重复提取数据,那么这个时候就需要使用到线程的排他锁了. 在c#里面其实很简单,下面先来看一个简单的小例子 Thread pingTask = new Thread(new ThreadStart(delegate { //从数据库获取1000条数 var list = getdata(); })); //启动线程 pingTask.Start(); 如果这个时候我们开启多个线程 代码如下 for (int i = 0; i

Java编程实现排他锁代码详解

一 .前言 某年某月某天,同事说需要一个文件排他锁功能,需求如下: (1)写操作是排他属性 (2)适用于同一进程的多线程/也适用于多进程的排他操作 (3)容错性:获得锁的进程若Crash,不影响到后续进程的正常获取锁 二 .解决方案 1. 最初的构想 在Java领域,同进程的多线程排他实现还是较简易的.比如使用线程同步变量标示是否已锁状态便可.但不同进程的排他实现就比较繁琐.使用已有API,自然想到 java.nio.channels.FileLock:如下 /** * @param file

详解python多线程之间的同步(一)

引言: 线程之间经常需要协同工作,通过某种技术,让一个线程访问某些数据时,其它线程不能访问这些数据,直到该线程完成对数据的操作.这些技术包括临界区(Critical Section),互斥量(Mutex),信号量(Semaphore),事件Event等. Event threading库中的event对象通过使用内部一个flag标记,通过flag的True或者False的变化来进行操作.      名称                                      含义 set( )

浅谈Python3多线程之间的执行顺序问题

一个多线程的题:定义三个线程ID分别为ABC,每个线程打印10遍自己的线程ID,按ABCABC--的顺序进行打印输出. 我的解法: from threading import Thread, Lock # 由_acquire解锁执行后释放_release锁 def _print(_id: str, _acquire: Lock, _release: Lock) -> None: for i in range(10): _acquire.acquire() print(f"id:{_id}&

关于多线程常用方法以及对锁的控制(详解)

1.sleep() 使当前线程(即调用该方法的线程)暂停执行一段时间,让其他线程有机会继续执行,但它并不释放对象锁.也就是如果有Synchronized同步块,其他线程仍然不同访问共享数据.注意该方法要捕获异常 比如有两个线程同时执行(没有Synchronized),一个线程优先级为MAX_PRIORITY,另一个为MIN_PRIORITY,如果没有Sleep()方法,只有高优先级的线程执行完成后,低优先级的线程才能执行:但当高优先级的线程sleep(5000)后,低优先级就有机会执行了. 总之

C#基于委托实现多线程之间操作的方法

本文实例讲述了C#基于委托实现多线程之间操作的方法.分享给大家供大家参考,具体如下: 有的时候我们要起多个线程,更多的时候可能会有某个线程会去操作其他线程里的属性. 但是线程是并发的,一般的调用是无法实现我们的要求的. 于是,我们在这里就可以用委托,代码如下 private delegate void DelegateInfo(); private delegate void DelegateIsEnd(); //这个是线程调用其他线程的方法 private void Dowork() { //

Python实现的多线程同步与互斥锁功能示例

本文实例讲述了Python实现的多线程同步与互斥锁功能.分享给大家供大家参考,具体如下: #! /usr/bin/env python #coding=utf-8 import threading import time ''' #1.不加锁 num = 0 class MyThread(threading.Thread): def run(self): global num time.sleep(1) #一定要sleep!!! num = num + 1 msg = self.name + '

mysql共享锁与排他锁用法实例分析

本文实例讲述了mysql共享锁与排他锁用法.分享给大家供大家参考,具体如下: mysql锁机制分为表级锁和行级锁,本文就和大家分享一下我对mysql中行级锁中的共享锁与排他锁进行分享交流. 共享锁又称为读锁,简称S锁,顾名思义,共享锁就是多个事务对于同一数据可以共享一把锁,都能访问到数据,但是只能读不能修改. 排他锁又称为写锁,简称X锁,顾名思义,排他锁就是不能与其他所并存,如一个事务获取了一个数据行的排他锁,其他事务就不能再获取该行的其他锁,包括共享锁和排他锁,但是获取排他锁的事务是可以对数据

Java多线程并发编程和锁原理解析

这篇文章主要介绍了Java多线程并发编程和锁原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 一.前言 最近项目遇到多线程并发的情景(并发抢单&恢复库存并行),代码在正常情况下运行没有什么问题,在高并发压测下会出现:库存超发/总库存与sku库存对不上等各种问题. 在运用了 限流/加锁等方案后,问题得到解决. 加锁方案见下文. 二.乐观锁 & 悲观锁 1.乐观锁 顾名思义,就是很乐观,每次去拿数据的时候都认为别人不会修改,所以不会上锁

Python多线程操作之互斥锁、递归锁、信号量、事件实例详解

本文实例讲述了Python多线程操作之互斥锁.递归锁.信号量.事件.分享给大家供大家参考,具体如下: 互斥锁: 为什么要有互斥锁:由于多线程是并行的,如果某一线程取出了某一个数据将要进行操作,但它还没有那么快执行完操作,这时候如果另外一个线程也要操作这个数据,那么这个数据可能会因为两次操作而发生错误 import time,threading x=6 def run1(): print("run1我拿到了数据:",x) print("我现在还不想操作,先睡一下")