轻量级 Lock Free 线程安全的 QueueT 的C#2.0实现

最近在维护一些C# 2.0的代码....发现各种线程不安全的实现

2.0里面又没有ConcurrentCollection的相关类

不得已,自己写了一个,

本来想用传统的lock实现的, 不过考虑到其中的操作非常轻量级...最终还是用了Lock Free

使用原子操作 InterLocked 替换掉常用的lock关键字

    public sealed class SafedQueue<T>    {#region private Fieldsprivate int isTaked = 0;private Queue<T> queue = new Queue<T>();private int MaxCount = 1000 * 1000;#endregion

public void Enqueue(T t)        {try            {while (Interlocked.Exchange(ref isTaked, 1) != 0)                {                }this.queue.Enqueue(t);            }finally            {                Thread.VolatileWrite(ref isTaked, 0);            }        }

public T Dequeue()        {try            {while (Interlocked.Exchange(ref isTaked, 1) != 0)                {                }                T t = this.queue.Dequeue();return t;            }finally            {                Thread.VolatileWrite(ref isTaked, 0);            }        }

public bool TryEnqueue(T t)        {try            {for (int i = 0; i < MaxCount; i++)                {if (Interlocked.Exchange(ref isTaked, 1) == 0)                    {this.queue.Enqueue(t);return true;                    }                }return false;            }finally            {                Thread.VolatileWrite(ref isTaked, 0);            }        }

public bool TryDequeue(out T t)        {try            {for (int i = 0; i < MaxCount; i++)                {if (Interlocked.Exchange(ref isTaked, 1) == 0)                    {                        t = this.queue.Dequeue();return true;                    }                }                t = default(T);return false;            }finally            {                Thread.VolatileWrite(ref isTaked, 0);            }        }    }

Try起头的方法都有尝试次数限制,超过限制以后就退出并返回false

转载于:https://www.cnblogs.com/PurpleTide/archive/2012/03/18/2404608.html

轻量级 Lock Free 线程安全的 QueueT 的C#2.0实现相关推荐

educoder 使用线程锁(lock)实现线程同步_性能：Lock的锁之优化
Lock / synchronized Lock锁的基本操作是通过乐观锁实现的,由于Lock锁也会在阻塞时被挂起,依然属于悲观锁 synchronizedLock实现方式JVM层实现Java底层代码实 ...
educoder 使用线程锁(lock)实现线程同步_Python并行编程(二)：多线程锁机制利用Lock与RLock实现线程同步
什么是锁机制? 要回答这个问题,我们需要知道为什么需要使用锁机制.前面我们谈到一个进程内的多个线程的某些资源是共享的,这也是线程的一大优势,但是也随之带来一个问题,即当两个及两个以上的线程同时访问共享 ...
使用lock同步线程，建立了10个线程实例
在C#中处理同步过对指定对象的加锁和解锁可以实现同步代码段的访问. 在.NET的System.Threading命名空间中提供了Monitor类来实现加锁与解锁.该类中的方法都是静态的. 如下表: ...
创建线程（Lock()、线程池、Callable()）及线程通信
package com.xt.java;import java.util.concurrent.locks.ReentrantLock;/*** 解决线程安全问题的方式三:Lock锁 -->JD ...
使用线程锁(lock)实现线程同步_一文搞懂Java多线程使用方式、实现原理以及常见面试题...
本系列文章将整理到我在GitHub上的<Java面试指南>仓库,更多精彩内容请到我的仓库里查看 https://github.com/h2pl/Java-Tutorial 喜欢的话麻烦点下 ...
educoder 使用线程锁(lock)实现线程同步_线程间的通信（一）
这篇文章主要从4个角度来讲多线程间的通信: 使用wait/notify实现线程间的通信生产者/消费者模式的实现方法join的使用 ThreadLocal类的使用等待/通知机制的实现: (1)wa ...
《JUC并发编程 - 基础篇》JUC概述 | Lock接口 | 线程间通信 | 多线程锁 | 集合线程安全
多线程随机数组生成+双线程快速排序（C++实现）（0.2秒排100W个数字）
简述用很多个线程进行随机数的生成用两个线程来进行数组的排序基于的算法是快速排序算法. 基本可以做到 0.2秒左右的时间排完100W个数字 #include <iostream> us ...
java sleep的意义_java 线程Thread.Sleep详解 Thread.Sleep(0)的作用
我们可能经常会用到 Thread.Sleep 函数来使线程挂起一段时间.那么你有没有正确的理解这个函数的用法呢? 思考下面这两个问题: 1.假设现在是 2008-4-7 12:00:00.000,如果 ...

轻量级 Lock Free 线程安全的 QueueT 的C#2.0实现

轻量级 Lock Free 线程安全的 QueueT 的C#2.0实现相关推荐

最新文章

热门文章