c#

位置:IT落伍者 >> c# >> 浏览文章

C#多线程学习—生产者和消费者(1)


发布日期:2023年02月13日
 
C#多线程学习—生产者和消费者(1)

前面说过每个线程都有自己的资源但是代码区是共享的即每个线程都可以执行相同的函数这可能带来的问题就是几个线程同时执行一个函数导致数据的混乱产生不可预料的结果因此我们必须避免这种情况的发生

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

lock(expression) statement_block

expression代表你希望跟蹤的对象通常是对象引用

如果你想保护一个类的实例一般地你可以使用this如果你想保护一个静态变量(如互斥代码段在一个静态方法内部)一般使用类名就可以了

而statement_block就是互斥段的代码这段代码在一个时刻内只可能被一个线程执行

下面是一个使用lock关键字的典型例子在注释里说明了lock关键字的用法和用途

示例如下

using System;

using SystemThreading;

namespace ThreadSimple

{

internal class Account

{

int balance;

Random r = new Random();

internal Account(int initial)

{

balance = initial;

}

internal int Withdraw(int amount)

{

if (balance < )

{

//如果balance小于则抛出异常

throw new Exception(Negative Balance);

}

//下面的代码保证在当前线程修改balance的值完成之前

//不会有其他线程也执行这段代码来修改balance的值

//因此balance的值是不可能小于

lock (this)

{

ConsoleWriteLine(Current Thread:+ThreadCurrentThreadName);

//如果没有lock关键字的保护那么可能在执行完if的条件判断之后

//另外一个线程却执行了balance=balanceamount修改了balance的值

//而这个修改对这个线程是不可见的所以可能导致这时if的条件已经不成立了

//但是这个线程却继续执行balance=balanceamount所以导致balance可能小于

if (balance >= amount)

{

ThreadSleep();

balance = balance amount;

return amount;

}

else

{

return ; // transaction rejected

}

}

}

internal void DoTransactions()

{

for (int i = ; i < ; i++)

Withdraw(rNext( ));

}

}

internal class Test

{

static internal Thread[] threads = new Thread[];

public static void Main()

{

Account acc = new Account ();

for (int i = ; i < ; i++)

{

Thread t = new Thread(new ThreadStart(accDoTransactions));

threads[i] = t;

}

for (int i = ; i < ; i++)

threads[i]Name=iToString();

for (int i = ; i < ; i++)

threads[i]Start();

ConsoleReadLine();

}

}

}

               

上一篇:C#中的Namespace详解[1]

下一篇:用C#在Word文档中搜索文本