队列处理器 WorkQueue<T>
2010-08-09 11:44
537 查看
代码
//方法1 WorkQueue<xxx> writeWQ = new WorkQueue<xxx>(5, 1000); //有重载,最多开辟5个线程同时处理,队列大小设为1000,如果超出则不处理 for (int a = 0; a < 1000000; a++) { //此方法按常理会立即返回,因为执行交给 WorkQueue 处理了 writeWQ.Enqueue(delegate(xxx msg) { //处理 }); } //方法2,执行一个匿名委托 WorkQueue writeWQ = new WorkQueue(5, 1000); //有重载,最多开辟5个线程同时处理,队列大小设为1000,如果超出则不处理 for (int a = 0; a < 1000000; a++) { //此方法按常理会立即返回,因为执行交给 WorkQueue 处理了 writeWQ.Enqueue(delegate() { //处理 }); }
相关文章推荐
- Volley源码解析<四> RequestQueue请求队列
- 队列<queue>
- priority_queue<int,vector<int>,greater<int>>优先队列 按照由小到大顺序
- 构造队列,网易,想直接修改队列中的值,就用queue<int*>
- priority_queue<int,vector<int>,greater<int>>优先队列 按照由小到大顺序
- 不可变队列ImmuableQueue<E>
- priority_queue<int,vector<int>,greater<int>>优先队列,按照从小到大
- ConcurrentQueue<T>高效的线程安全的队列
- priority_queue<int,vector<int>,greater<int>>优先队列 按照由小到大顺序
- 类 ArrayBlockingQueue<E>(一个由数组支持的有界阻塞队列。)
- 队列<queue>中的常用函数
- 【C++】队列容器 头文件 #include<queue> 解读
- [C++基础]队列<queue>中的常用函数
- c#高效的线程安全队列ConcurrentQueue<T>(上)
- priority_queue<int,vector<int>,greater<int>>优先队列 按照由小到大顺序
- Queue<>队列
- 高效的线程安全队列ConcurrentQueue<T>(上)
- 高效的线程安全队列ConcurrentQueue<T>(上)
- 泛型容器单元(Generics.Collections)[2]: TQueue<T> 队列列表
- 优先级队列(java.util.PriorityQueue<E>)