zoukankan      html  css  js  c++  java

  • AsyncManualResetEvent

    (译)Async同步基元，Part 1 AsyncManualResetEvent

    =============C#.Net 篇目录==============

     

    最近在学习.NET4.5关于“并行任务”的使用。“并行任务”有自己的同步机制，没有显示给出类似如旧版本的：事件等待句柄、信号量、lock、ReaderWriterLock……等同步基元对象，但我们可以沿溪这一编程习惯，那么这系列翻译就是给“并行任务”封装同步基元对象。翻译资源来源《（译）关于Async与Await的FAQ》

    1. Async同步基元，Part 1 AsyncManualResetEvent
    2. Async同步基元，Part 2 AsyncAutoResetEvent
    3. Async同步基元，Part 3 AsyncCountdownEvent
    4. Async同步基元，Part 4 AsyncBarrier
    5. Async同步基元，Part 5 AsyncSemaphore
    6. Async同步基元，Part 6 AsyncLock
    7. Async同步基元，Part 7 AsyncReaderWriterLock

     

    开始：Async同步基元，Part 1 AsyncManualResetEvent

    基于任务异步模式(TAP)不仅仅是关于开始然后异步等待完成的异步操作，更概括的说，任务可以用来指代各种事件，使你能够等待任何事的条件发生。我们甚至可以使用任务来构建简单的同步基元，这些同步基元类似.NET原生提供的非任务版本，但是它们允许等待异步完成。

    基本同步基元之一：事件等待句柄，它们存在于.NET Framework。ManualResetEvent 和AutoResetEvent和.NET 4为ManualResetEvent新增的轻量版本ManualResetEventSlim。事件等待句柄就是一方能等待另一方的信号。比如ManualResetEvent，他会在调用Set()后保持信号直到显示调用Reset()。

    TaskCompletionSource<TResult>本身就是一个事件等待句柄，仅仅是缺少Reset()方法。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    // 表示未绑定到委托的 System.Threading.Tasks.Task<TResult> 的制造者方，
    // 并通过 Tasks.TaskCompletionSource<TResult>.Task属性提供对使用者方的访问。
    public class TaskCompletionSource<TResult>
    {
        public TaskCompletionSource();
     
        // 获取由此 Tasks.TaskCompletionSource<TResult> 创建的 Tasks.Task<TResult>。
        public Task<TResult> Task { get; }
     
        // 将基础 Tasks.Task<TResult> 转换为 Tasks.TaskStatus.Canceled状态。
        public void SetCanceled();
        public bool TrySetCanceled();
     
        // 将基础 Tasks.Task<TResult> 转换为 Tasks.TaskStatus.Faulted状态。
        public void SetException(Exception exception);
        public void SetException(IEnumerable<Exception> exceptions);
        public bool TrySetException(Exception exception);
        public bool TrySetException(IEnumerable<Exception> exceptions);
     
        // 尝试将基础 Tasks.Task<TResult> 转换为 TaskStatus.RanToCompletion状态。
        public bool TrySetResult(TResult result);
        ……       
    }

    TaskCompletionSource<TResult>开始于无信号，它指代的任务不能完成，因此，等待这个任务的“异步方法”也不能完成。(Try)Set*方法充当信号，将任务切换到完成状态，这样才能完成等待任务。因此我们可以很容易基于TaskCompletionSource<TResult>来构建一个AsyncManualResetEvent。它可以为我们提供缺失的Reset()能力。接下来我们构建此AsyncManualResetEvent。

    这是我们将构建的目标类型：

    1
    2
    3
    4
    5
    6
    public class AsyncManualResetEvent
    {
        public Task WaitAsync();
        public void Set();
        public void Reset();
    }

    WaitAsync()和Set()方法非常简单，直接封装TaskCompletionSource<bool>实例成员，如下：

    1
    2
    3
    4
    5
    6
    7
    public class AsyncManualResetEvent
    {
        private volatile TaskCompletionSource<bool> m_tcs = new TaskCompletionSource<bool>();
        public Task WaitAsync() { return m_tcs.Task; }
        public void Set() { m_tcs.TrySetResult(true); }
        …
    }

    剩下的只有Reset()方法了。我们的目标是使随后调用的WaitAsync()中返回的Task无法完成。因为Task最终状态只有完成状态（eg：正常完成、取消、异常），所以我们需要切换一个新的TaskCompletionSource<bool>实例。这样做，我们需要确保如果多个线程同时调用Reset()、Set()和WaitAsync()， WaitAsync()不会返回孤立的Task（即，我们不希望一个线程调用WaitAsync()返回一个不能完成的Task后，另一个线程又对该Task调用Set()）。为了达到此目的，我们将确保如果当前Task已经完成就切换一个新的Task，并且还确保这个切换操作的原子性。（当然，还有其他策略实现此目标，这仅仅是我选择的一个特定例子）

    注意：关键字volitile和Interlocked类的使用。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    public class AsyncManualResetEvent
    {
        private volatile TaskCompletionSource<bool> m_tcs = new TaskCompletionSource<bool>();
     
        public Task WaitAsync() { return m_tcs.Task; }
        public void Set() { m_tcs.TrySetResult(true); } 
        public void Reset()
        {
            while (true)
            {
                var tcs = m_tcs;
                if (!tcs.Task.IsCompleted ||
                    Interlocked.CompareExchange(ref m_tcs, new TaskCompletionSource<bool>(), tcs) == tcs)
                    return;
            }
        }
    }

    到此，我们的AsyncManualResetEvent已经完成。然而，还有一个重要的潜在行为要记住。在之前的文章中，我们谈论过延续任务和他们是如何同步执行，这意味着延续任务将作为任务完成的一部分执行，在同一个线程上同步完成任务。对于TaskCompletionSource<TResult>，这意味着同步延续任务将作为(Try)Set*方法的一部分执行，也就是说，在AsyncManualResetEvent例子中，延续任务将作为Set()方法的一部分执行。根据你的需求，如果你不希望这种事情发生，有一些替代的方法。一种方法是异步完成之后，调用Set()进行阻塞，直到任务真真完成（只是任务本身，不包括任务的延续任务）。Eg：

    1
    2
    3
    4
    5
    6
    7
    public void Set()
    {
        var tcs = m_tcs;
        Task.Factory.StartNew(s => ((TaskCompletionSource<bool>)s).TrySetResult(true), tcs
           , CancellationToken.None, TaskCreationOptions.PreferFairness, TaskScheduler.Default);
        tcs.Task.Wait();
    }

    当然，还有其他可能的方法，如何实现取决于你的需求。

     

     感谢你的观看……

     

    原文：http://blogs.msdn.com/b/pfxteam/archive/2012/02/11/10266920.aspx

    作者：Stephen Toub - MSFT


    作者：滴答的雨 
    出处：http://www.cnblogs.com/heyuquan/ 
    本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。 

    欢迎园友讨论下自己的见解，及推荐更好资料。 
    本文如对读者有帮助，请帮 下。 
    谢谢！！！  （快捷回复 ： ）     (*^_^*)

    分类: C#.Net 篇
  • 相关阅读:
    jmeter的基本功能使用详解
    服务器资源监控插件(jmeter)
    前端技术之--CSS
    前端技术之--HTML
    TCP/IP基础知识
    TCP/IP、Http的区别
    关于性能调优
    如何修改Docker已运行实例的端口映射
    Mysql 主从同步配置
    Presto的基本概念
  • 原文地址：https://www.cnblogs.com/Leo_wl/p/2836132.html
Copyright © 2011-2022 走看看