Queue<T>队列-创新互联
=====================================Document.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConsoleApplication2
{
public class Document//文本类
{
//标题
public string Title { get; private set; }
//内容
public string Content { get; private set; }
public Document(string title, string content)
{
this.Title = title;
this.Content = content;
}
public override string ToString()
{
return string.Format("标题:{0};内容:{1};",this.Title,this.Content);
}
}
}=====================================DocumentManage.cs
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Collections;
namespace ConsoleApplication2
{
public class DocumentManage//文本操作类
{
Queue doc = new Queue();
//向队列中添加元素
public void AddDocument(Document d)
{
lock (this)//同步操作
doc.Enqueue(d);
}
//读取头元素,并删除
public Document GetDocument()
{
lock (this)
return doc.Dequeue();
}
//判断队列中有没有元素
public bool IsAvailableDocument
{
get {
return doc.Count > 0;
}
}
}
} =====================================ProcessDocument.cs
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading;
namespace ConsoleApplication2
{
public class ProcessDocument//开启线程读取文档中的元素
{
private DocumentManage dm;
public ProcessDocument(DocumentManage d)
{
dm = d;
}
///
/// 开启线程读取文档中的元素
///
///
public static void Start(DocumentManage d)
{
new Thread(new ProcessDocument(d).Run).Start();
}
private void Run()
{
while (true)
{
if (dm.IsAvailableDocument)//判断队列中有没有元素
{
Console.WriteLine(dm.GetDocument().ToString());
}
}
}
}
}=====================================主程序
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConsoleApplication2
{
class Program
{
static void Main(string[] args)
{
DocumentManage dm = new DocumentManage();
ProcessDocument.Start(dm);//开启线程读取文档
for (int i = 0; i < 10000; i++)//向队列中添加10000个元素
{
Document doc = new Document(i.ToString(), i.ToString());
dm.AddDocument(doc);
Console.WriteLine(doc.ToString() + ".....New");
}
Console.ReadKey();
}
}
}
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
本文名称:Queue<T>队列-创新互联
转载源于:http://www.jxjierui.cn/article/ediee.html


咨询
建站咨询
