由一个订单推送想到了ObservableCollection的神奇用法

2024-08-29 23:32

本文主要是介绍由一个订单推送想到了ObservableCollection的神奇用法,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

最近在做taobao的一个卖家应用,需要订阅taobao的订单推送,示例代码如下:

 

 

看到上面的OnMessage场景之后,我突然就鬼使神差的在想最近写的一个服务,其中的一个功能是需要定时的轮询一个集合,这样可以方便的把数据取出来,但是

轮训对我来说是被迫的,我急迫需要一种机制对一个集合的数据进行监控,比如List,Dictionary等等,这样我就很方便的对数据进行后续处理,而不是我定时的去轮

训一个集合,然后我就想到了wpf里面有一个玩法叫做“属性依赖”,然后就想到了今天要说的“ObservableCollection”集合,下面我们就来看看这个集合的玩法。

 

一:先看玩法

  首先我对集合进行Add和Remove操作,并且给他注册个change事件,然后用工作线程去执行change事件的逻辑,看看给我什么反馈,神奇的效果即刻开始。

复制代码
 class Program{static void Main(string[] args){ObservableCollection<string> list = new ObservableCollection<string>() { "1" };list.CollectionChanged += list_CollectionChanged;for (int i = 0; i < 1000; i++){if (i % 3 == 1){list.RemoveAt(0);}else{list.Add(i.ToString());}}Console.WriteLine("全部结束!!!");Console.Read();}static void list_CollectionChanged(object sender, NotifyCollectionChangedEventArgs e){//为了不阻止主线程Add,事件用 “工作线程”处理Task.Factory.StartNew((o) =>{var obj = o as NotifyCollectionChangedEventArgs;switch (obj.Action){case NotifyCollectionChangedAction.Add:Console.WriteLine("当前线程:{0}, 操作是:{1} 数据:{2}", Thread.CurrentThread.ManagedThreadId, obj.Action.ToString(), obj.NewItems[0]);break;case NotifyCollectionChangedAction.Move:break;case NotifyCollectionChangedAction.Remove:Console.WriteLine("当前线程:{0}, 操作是:{1} 数据:{2}", Thread.CurrentThread.ManagedThreadId, obj.Action.ToString(), obj.OldItems[0]);break;case NotifyCollectionChangedAction.Replace:break;case NotifyCollectionChangedAction.Reset:break;default:break;}Thread.Sleep(1000);}, e);}}
复制代码

 

     从表象来看,CollectionChanged 已经完全的监控到了集合的各个动作,包括Add,Remove,很显然,这比我去轮训数据好多了,不过用的话,谁都会用,

关键是要看看怎么实现的,下面我们来剖析下。

 

二:简单分析下源码

  首先我们会发现,ObservableCollection继承了一个Collection并且实现了一个“属性通知”和“集合通知”的两个接口INotifyCollectionChanged,

 INotifyPropertyChanged)。

 

然后我们发现Add方法是由父类提供,然后调用ObservableCollection中提供了InsertItem方法,如下图。

 

 

可以看到,在我们上层的Add方法中,其实调用的是InsertItem方法,并且在最后我们看到了一个核心方法OnCollectionChanged,是不是很开心。。。。

下面跟着我一起去看看

 

最终我们开心的看到了这个类的触发机制,只不过是在Add/Remove方法的最后面做了一个事件触发的方法,同时我们也看到了,这是一个同步操作,这就意味着,

默认情况下,我的CollectionChanged逻辑是会阻止上层的Add操作的,这个需要特别注意。

这篇关于由一个订单推送想到了ObservableCollection的神奇用法的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1119157

相关文章

Python中logging模块用法示例总结

《Python中logging模块用法示例总结》在Python中logging模块是一个强大的日志记录工具,它允许用户将程序运行期间产生的日志信息输出到控制台或者写入到文件中,:本文主要介绍Pyt... 目录前言一. 基本使用1. 五种日志等级2.  设置报告等级3. 自定义格式4. C语言风格的格式化方法

SpringBoot 获取请求参数的常用注解及用法

《SpringBoot获取请求参数的常用注解及用法》SpringBoot通过@RequestParam、@PathVariable等注解支持从HTTP请求中获取参数,涵盖查询、路径、请求体、头、C... 目录SpringBoot 提供了多种注解来方便地从 HTTP 请求中获取参数以下是主要的注解及其用法:1

Java中HashMap的用法详细介绍

《Java中HashMap的用法详细介绍》JavaHashMap是一种高效的数据结构,用于存储键值对,它是基于哈希表实现的,提供快速的插入、删除和查找操作,:本文主要介绍Java中HashMap... 目录一.HashMap1.基本概念2.底层数据结构:3.HashCode和equals方法为什么重写Has

Android协程高级用法大全

《Android协程高级用法大全》这篇文章给大家介绍Android协程高级用法大全,本文结合实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友跟随小编一起学习吧... 目录1️⃣ 协程作用域(CoroutineScope)与生命周期绑定Activity/Fragment 中手

Python异步编程之await与asyncio基本用法详解

《Python异步编程之await与asyncio基本用法详解》在Python中,await和asyncio是异步编程的核心工具,用于高效处理I/O密集型任务(如网络请求、文件读写、数据库操作等),接... 目录一、核心概念二、使用场景三、基本用法1. 定义协程2. 运行协程3. 并发执行多个任务四、关键

Python中yield的用法和实际应用示例

《Python中yield的用法和实际应用示例》在Python中,yield关键字主要用于生成器函数(generatorfunctions)中,其目的是使函数能够像迭代器一样工作,即可以被遍历,但不会... 目录python中yield的用法详解一、引言二、yield的基本用法1、yield与生成器2、yi

深度解析Python yfinance的核心功能和高级用法

《深度解析Pythonyfinance的核心功能和高级用法》yfinance是一个功能强大且易于使用的Python库,用于从YahooFinance获取金融数据,本教程将深入探讨yfinance的核... 目录yfinance 深度解析教程 (python)1. 简介与安装1.1 什么是 yfinance?

Python库 Django 的简介、安装、用法入门教程

《Python库Django的简介、安装、用法入门教程》Django是Python最流行的Web框架之一,它帮助开发者快速、高效地构建功能强大的Web应用程序,接下来我们将从简介、安装到用法详解,... 目录一、Django 简介 二、Django 的安装教程 1. 创建虚拟环境2. 安装Django三、创

python中update()函数的用法和一些例子

《python中update()函数的用法和一些例子》update()方法是字典对象的方法,用于将一个字典中的键值对更新到另一个字典中,:本文主要介绍python中update()函数的用法和一些... 目录前言用法注意事项示例示例 1: 使用另一个字典来更新示例 2: 使用可迭代对象来更新示例 3: 使用

python连接sqlite3简单用法完整例子

《python连接sqlite3简单用法完整例子》SQLite3是一个内置的Python模块,可以通过Python的标准库轻松地使用,无需进行额外安装和配置,:本文主要介绍python连接sqli... 目录1. 连接到数据库2. 创建游标对象3. 创建表4. 插入数据5. 查询数据6. 更新数据7. 删除