首页 > 其他 > 详细

xian3

时间:2014-02-14 22:41:07      阅读:405      评论:0      收藏:0      [点我收藏+]

C#多线程:使用Semaphore类限制资源并发访问数

考虑这样的一个场景:一个停车场的只含一定数量的停车位,只有当停车场中还有空位时,停车场的入口才会打开。C#提供了Semaphore类来处理这种场景。Semaphore类可以在构造时指定资源数量,使用WaitOne方法等待一个资源,使用Release方法释放一个资源。示例代码:

 

bubuko.com,布布扣
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

using System.Threading;

namespace ProcessTest
{
    class Program
    {
        static Semaphore semaphore;

        static void Main(string[] args)
        {
            //创建一个限制资源类
            //资源数为5,开放资源数为2
            //主线程自动占有3个资源
            semaphore = new Semaphore(2, 5);

            //开启3个线程,让它们竞争剩余的2个资源
            for (int i = 0; i < 3; i++)
            {
                Thread t = new Thread(new ThreadStart(WorkerProc));
                t.Name = "Thread" + i;
                t.Start();
                Thread.Sleep(30);
            }

            System.Console.ReadKey();
        }

        static void WorkerProc()
        {
            for (int i = 0; i < 3; i++)
            {
                //等一个资源信号
                semaphore.WaitOne();
                Console.WriteLine(Thread.CurrentThread.Name + ": Begin");
                Thread.Sleep(200);
                Console.WriteLine(Thread.CurrentThread.Name + ": End");
                //释放资源
                semaphore.Release();
            }
        }
    }
}
bubuko.com,布布扣

 

C#多线程:Interlocked类操作

 System.Threading.Interlocked类为多个线程共享的变量提供原子操作。

为整型类提供原子类操作

  经验显示,那些需要在多线程情况下被保护的资源通常是整型值,且这些整型值在多线程下最常见的操作就是递增、递减或相加操作。Interlocked类提供了一个专门的机制用于完成这些特定的操作。这个类提供了Increment、Decrement、Add静态方法用于对int或long型变量的递增、递减或相加操作。

  示例代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
 
using System.Threading;
 
namespace ProcessTest
{
    class Program
    {
        static int counter = 0;
 
        static void Main(string[] args)
        {
            Thread t1 = new Thread(new ThreadStart(F1));
            Thread t2 = new Thread(new ThreadStart(F2));
 
            t1.Start();
            t2.Start();
 
            t1.Join();
            t2.Join();
 
            System.Console.ReadKey();
        }
 
        static void F1()
        {
            for (int i = 0; i < 5; i++)
            {
                Interlocked.Increment(ref counter);
                System.Console.WriteLine("Counter++ {0}", counter);
                Thread.Sleep(10);
            }
        }
 
        static void F2()
        {
            for (int i = 0; i < 5; i++)
            {
                Interlocked.Decrement(ref counter);
                System.Console.WriteLine("Counter-- {0}", counter);
                Thread.Sleep(10);
            }
        }
    }
}

  

xian3

原文:http://www.cnblogs.com/jiaoluo/p/3548781.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!