C#中Queue<T>类的使用以及部分方法的源码分析

Queue<T>类

表示对象的先进先出集合。

队列在按接收顺序存储消息方面非常有用,以便于进行顺序处理。 存储在 Queue,<T> 中的对象在一端插入,从另一端移除。

Queue<T> 的容量是 Queue<T> 可以包含的元素数。 当向 Queue<T> 中添加元素时,将通过重新分配内部数组来根据需要自动增大容量。

可通过调用 TrimExcess 来减少容量。

Queue<T> 接受 null 作为引用类型的有效值并且允许有重复的元素。

命名控件:System.Collections.Generic

程序集:System(在System.dll中)

语法:public class Queue<T>:IEnumerable<T>, ICollection, IEnumerable

List<T>实现了IList<T>、 ICollection<T>、IEnumerable<T>、IList、ICollection、IEnumerable接口

因此可以看出与List<T>相比:

Queue<T>没有继承ICollection<T>接口,因为这个接口定义的Add()和Remove()方法不能用于队列;

Queue<T>没有继承IList<T>接口,所以不能使用索引器访问队列。

所以队列只允许在队列的尾部添加元素,从队列的头部获取元素。

常用的Queue<T>类的成员:

Count : 返回队列中元素的个数。

Enqueue : 在队列一端添加一个元素。

Dequeue() : 从队列的头部读取和删除一个元素。如果调用Dequeue()时,队列中没有元素就会抛出异常InvalidOperationException异常。

Peek(): 在队列的头部取出一个元素,但不删除它。

TrimExcess():重置队列的容量。

/******************************************************************************************************************************/

常用Queue<T>类的成员函数的源码如下:

public T Dequeue()

{

if (this._size == 0)

{

ThrowHelper.ThrowInvalidOperationException(ExceptionResource.InvalidOperation_EmptyQueue);

}

T local = this._array[this._head];

this._array[this._head] = default(T);

this._head = (this._head + 1) % this._array.Length;

this._size--;

this._version++;

return local;

}

public void Enqueue(T item)

{

if (this._size == this._array.Length)

{

int capacity = (int) ((this._array.Length * 200L) / 100L);

if (capacity < (this._array.Length + 4))

{

capacity = this._array.Length + 4;

}

this.SetCapacity(capacity);

}

this._array[this._tail] = item;

this._tail = (this._tail + 1) % this._array.Length;

this._size++;

this._version++;

}

public T Peek()

{

if (this._size == 0)

{

ThrowHelper.ThrowInvalidOperationException(ExceptionResource.InvalidOperation_EmptyQueue);

}

return this._array[this._head];

}

public void TrimExcess()

{

int num = (int) (this._array.Length * 0.9);

if (this._size < num)

{

this.SetCapacity(this._size);

}

}

上诉方法使用到的SetCapacity函数的源码如下:

private void SetCapacity(int capacity)

{

T[] destinationArray = new T[capacity];

if (this._size > 0)

{

if (this._head < this._tail)

{

Array.Copy(this._array, this._head, destinationArray, 0, this._size);

}

else

{

Array.Copy(this._array, this._head, destinationArray, 0, this._array.Length - this._head);

Array.Copy(this._array, 0, destinationArray, this._array.Length - this._head, this._tail);

}

}

this._array = destinationArray;

this._head = 0;

this._tail = (this._size == capacity) ? 0 : this._size;

this._version++;

}

/*****************************************************************************************************************************************/

示例:

下面的代码示例演示了 Queue<T> 泛型类的几个方法。 此代码示例创建一个具有默认容量的字符串队列,并使用 Enqueue 方法对五个字符串进行排队。 枚举队列元素,这不会更改队列的状态。 使用 Dequeue 方法使第一个字符串出列。 使用 Peek 方法查找队列中的下一项,然后使用 Dequeue 方法使该项出列。

使用 ToArray 方法创建一个数组并将队列元素复制到该数组,然后将该数组传递给接受 IEnumerable 的 Queue 构造函数以创建队列副本。 将显示副本的元素。

创建一个大小是队列大小两倍的数组,并使用 CopyTo 方法从数组中间开始复制数组元素。 再次使用 Queue1T> 构造函数创建第二个队列副本,此队列在开始处包含三个 null 元素。

使用 Contains 方法显示字符串“four”在第一个队列副本中,然后使用 Clear 方法清除此副本并由 Count 属性显示该队列为空。

using System;

using System.Collections.Generic;

class Example

{

public static void Main()

{

Queue1string> numbers = new Queue1string>();

numbers.Enqueue("one");

numbers.Enqueue("two");

numbers.Enqueue("three");

numbers.Enqueue("four");

numbers.Enqueue("five");

// A queue can be enumerated without disturbing its contents.

foreach( string number in numbers )

{

Console.WriteLine(number);

}

Console.WriteLine("\nDequeuing ‘{0}‘", numbers.Dequeue());

Console.WriteLine("Peek at next item to dequeue: {0}", numbers.Peek());

Console.WriteLine("Dequeuing ‘{0}‘", numbers.Dequeue());

// Create a copy of the queue, using the ToArray method and the

// constructor that accepts an IEnumerable.

Queue1string> queueCopy = new Queue1string>(numbers.ToArray());

Console.WriteLine("\nContents of the first copy:");

foreach( string number in queueCopy )

{

Console.WriteLine(number);

}

// Create an array twice the size of the queue and copy the

// elements of the queue, starting at the middle of the

// array.

string[] array2 = new string[numbers.Count * 2];

numbers.CopyTo(array2, numbers.Count);

// Create a second queue, using the constructor that accepts an

// IEnumerable(Of T).

Queue1string> queueCopy2 = new Queue1string>(array2);

Console.WriteLine("\nContents of the second copy, with duplicates and nulls:");

foreach( string number in queueCopy2 )

{

Console.WriteLine(number);

}

Console.WriteLine("\nqueueCopy.Contains(\"four\") = {0}", queueCopy.Contains("four"));

Console.WriteLine("\nqueueCopy.Clear()");

queueCopy.Clear();

Console.WriteLine("\nqueueCopy.Count = {0}", queueCopy.Count);

}

}

/* This code example produces the following output:

one

two

three

four

five

Dequeuing ‘one‘

Peek at next item to dequeue: two

Dequeuing ‘two‘

Contents of the copy:

three

four

five

Contents of the second copy, with duplicates and nulls:

three

four

five

queueCopy.Contains("four") = True

queueCopy.Clear()

queueCopy.Count = 0

*/

版权声明:本文为博主原创文章,未经博主允许不得转载。

时间: 2024-10-15 10:51:54

C#中Queue<T>类的使用以及部分方法的源码分析的相关文章

Java中的String为什么是不可变的? -- String源码分析

转:http://blog.csdn.net/zhangjg_blog/article/details/18319521 什么是不可变对象? 众所周知, 在Java中, String类是不可变的.那么到底什么是不可变的对象呢? 可以这样认为:如果一个对象,在它创建完成之后,不能再改变它的状态,那么这个对象就是不可变的.不能改变状态的意思是,不能改变对象内的成员变量,包括基本数据类型的值不能改变,引用类型的变量不能指向其他的对象,引用类型指向的对象的状态也不能改变. 区分对象和对象的引用 对于Ja

Cocos2dx-3.x 中CCCamera相机类详解及源码分析

Cocos2d-x 3.3版本中加入了相机这个类,该类在3D游戏中是必不可少的,在3D立体游戏中,往往需要视野角度的变化,通过相机的变换才能观察和体验整个游戏世界. CCCamera类基本使用 在游戏中一般有两种类型的相机:一种是透视相机,它在3D游戏中十分常见:另一种是正交相机,它没有透视相机的近大远小的效果而是相机内任何位置的物体大小比例都是一样的. 上图是透视相机的原理图,一般来说,我们通过以下代码创建: _camera = Camera::createPerspective(60, (G

(转)Android中的基类—抽取出来公共的方法

在Android中,一般来说一个应用会存在几十个页面,并且一个应用一般也会使用一个特定的主题,其中的页面的风格也是一致的,并且页面中的动画效果.页面的切换效果等也应该保持同样的风格,那么就需要一个基类,来完成页面的基础设置,这就是所谓的基类. 界面统一管理原因 当应用中的界面达到一定数量级时,如几十个界面,便于项目管理 提高界面的处理速度 避免由于多Activity导致的问题 界面统一管理的基础 当应用中的界面达到一定数量级时,为了能够让用户更容易操作上手,产品设计时会将界面显示风格进行统一.

关于java中ReentrantLock类的源码分析以及总结与例子

一,官方描述 关于ReentrantLock的官方描述,英文的就不贴出来了,这里我只贴出我自己翻译的描述: reentrant是一个跟synchronized具有相同行为和语义的持有锁来访问方法和语句的互斥锁,但是reentrant还拥有被扩展的能力. ReentrantLock会被线程拥有并且持续锁定,不会解锁.线程调用lock()方法返回后,则成功持有锁,否则这个锁正在被另一个线程所持有,只能等待另一个线程释放锁,如果当前线程拥有了锁,则调用lock()方法会立即返回,这个状态可以通过isH

JDK中String类的源码分析(二)

1.startsWith(String prefix, int toffset)方法 包括startsWith(*),endsWith(*)方法,都是调用上述一个方法 1 public boolean startsWith(String prefix, int toffset) { 2 char ta[] = value; 3 int to = toffset; 4 char pa[] = prefix.value; 5 int po = 0; 6 int pc = prefix.value.l

Android中的基类—抽取出来公共的方法

在Android中,一般来说一个应用会存在几十个页面,并且一个应用一般也会使用一个特定的主题,其中的页面的风格也是一致的,并且页面中的动画效果.页面的切换效果等也应该保持同样的风格,那么就需要一个基类,来完成页面的基础设置,这就是所谓的基类. 界面统一管理原因 当应用中的界面达到一定数量级时,如几十个界面,便于项目管理 提高界面的处理速度 避免由于多Activity导致的问题 界面统一管理的基础 当应用中的界面达到一定数量级时,为了能够让用户更容易操作上手,产品设计时会将界面显示风格进行统一.

《深入理解SPARK:核心思想与源码分析》——SparkContext的初始化(中)

<深入理解Spark:核心思想与源码分析>一书前言的内容请看链接<深入理解SPARK:核心思想与源码分析>一书正式出版上市 <深入理解Spark:核心思想与源码分析>一书第一章的内容请看链接<第1章 环境准备> <深入理解Spark:核心思想与源码分析>一书第二章的内容请看链接<第2章 SPARK设计理念与基本架构> 由于本书的第3章内容较多,所以打算分别开辟三篇随笔分别展现. <深入理解Spark:核心思想与源码分析>一

Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)----&gt;第6节: 异线程回收对象

Netty源码分析第八章: 高性能工具类FastThreadLocal和Recycler 第六节: 异线程回收对象 异线程回收对象, 就是创建对象和回收对象不在同一条线程的情况下, 对象回收的逻辑 我们之前小节简单介绍过, 异线程回收对象, 是不会放在当前线程的stack中的, 而是放在一个WeakOrderQueue的数据结构中, 回顾我们之前的一个图: 8-6-1 相关的逻辑, 我们跟到源码中: 首先从回收对象的入口方法开始, DefualtHandle的recycle方法: public

8.源码分析---从设计模式中看SOFARPC中的EventBus?

我们在前面分析客户端引用的时候会看到如下这段代码: // 产生开始调用事件 if (EventBus.isEnable(ClientStartInvokeEvent.class)) { EventBus.post(new ClientStartInvokeEvent(request)); } 这里用EventBus调用了一下post方法之后就什么也没做了,就方法名来看是发送了一个post请求,也不知道发给谁,到底有什么用. 所以这一节我们来分析一下EventBus这个类的作用. 首先我们来看一下