android 和 ios中实现类似C#的BackgroundWorker接口

2024-01-28 17:48
文章标签 c# 实现 android 接口 ios .net 类似 netcore backgroundworker

本文主要是介绍android 和 ios中实现类似C#的BackgroundWorker接口，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

移动应用为支持各种功能，大多采用了多线程技术。使用单独的线程执行某些任务，同时不影响界面的刷新，在线程执行过程中，可能需要通知一些信息给界面线程，在线程结束之后，需要告诉界面线程执行的结果，这是较为通用的一种线程执行方式。

    在C#中，实现该功能的类是BackgroundWorker, 而在android和ios中，并无类似的封装好的类。通常在开发应用的时候需要考虑可移植性，存在为多种平台开发相同应用的情况，为简化不同平台应用的开发，编程需要考虑相同的逻辑结构。因此在android和ios实现与BackgroundWorker类似的功能和接口。


1.C#的BackgroundWorker

    BackgroundWorker包含的主要属性和接口说明如下：

    主要属性:

    event DoWorkEventHandler DoWork;  //线程的主体
    event ProgressChangedEventHandler ProgressChanged;  //线程运行过程中的消息
    event RunWorkerCompletedEventHandler RunWorkerCompleted; //线程结束时的处理

    主要函数：

    void CancelAsync();  取消线程的运行
    void ReportProgress(int percentProgress, object userState);  //报告线程的消息
    void RunWorkerAsync(object argument);  //开始执行线程

    为了方面使用，可以将BackgroundWorker进行封装如下

    

    public class StarBackgroundWorker{private BackgroundWorker m_worker;public StarBackgroundWorker(){m_worker = new BackgroundWorker();}public void CancelAsync(){m_worker.CancelAsync();}public void RunAsync(DoWorkEventHandler DoWork, object userState, ProgressChangedEventHandler ProgressChanged, RunWorkerCompletedEventHandler RunWorkerCompleted){m_worker.DoWork += DoWork;m_worker.WorkerSupportsCancellation = true;m_worker.RunWorkerCompleted += RunWorkerCompleted;if (ProgressChanged != null){m_worker.ProgressChanged += ProgressChanged;m_worker.WorkerReportsProgress = true;}m_worker.RunWorkerAsync(userState);}public void ReportProgress(int percentProgress, object userState){m_worker.ReportProgress(percentProgress, userState);}}

    使用方法：

StarCoreBackgroundWorker myworker = new StarCoreBackgroundWorker();
myworker.RunAsync((object sender1, DoWorkEventArgs e1) =>{BackgroundWorker worker = sender1 as BackgroundWorker;//线程的主体},null,(object sender1, ProgressChangedEventArgs e1) =>{//--在界面线程中执行，可以刷新界面},(object sender1, RunWorkerCompletedEventArgs e1) =>{//--在界面线程中处理，线程运行结束后的处理}
);


2.Android中实现类似BackgroundWorker的功能

Android中使用java编程，通常创建线程使用Thread和Runnable，线程与界面线程通信使用消息的方式，从界面线程中的handler获取一条消息结构，填充参数，使用sendMessage将消息发送给界面线程。界面线程的Handler获取消息队列中的消息进行处理。利用这些方式，可以实现类似c# BackgroundWorker功能


a. 封装Handler

    由于采用Handler处理所有BackgroundWorker线程中的消息，为了区分不同的线程，需要线程在创建时进行登记。代码如下：

public class StarUIHander {static public Handler handler;static int InvokeTag = 0;static HashMap<Integer,HandlerCallBack> CallBackList;public interface HandlerCallBack {void Invoke(Message msg);}static int Register(HandlerCallBack CallBack){int Val = InvokeTag;CallBackList.put(InvokeTag,CallBack);InvokeTag ++;return Val;}static void Remove(int Which){CallBackList.remove(Which);}static void InitStarUIHander(){handler = new android.os.Handler() {public void handleMessage(Message msg) {HandlerCallBack CallBack = CallBackList.get(msg.what);if( CallBack != null )CallBack.Invoke(msg);}};CallBackList = new HashMap<Integer,HandlerCallBack>();}
}


    在android应用主Activity中，调用InitStarUIHander初始化Handler，对于创建的线程，调用Register注册消息处理函数，获取标识，使用该标识发送消息时。

b. 实现BackgroundWorker功能

    在实现BackgroundWorker之前，参照c#的定义，需要实现一些相关的接口。有以下几个：
    CancellationTokenSource, ProgressChangedEventArgs, DoWorkEventArgs，RunWorkerCompletedEventArgs，具体代码可参考附件

    

public BackgroundWorker()
{//_dispatcher = this.Dispatcher;cts = new CancellationTokenSource();HandlerQueue = StarUIHander.Register(new StarUIHander.HandlerCallBack() {@Override public void Invoke(Message msg) {Object[] Para = (Object[])msg.obj;switch ((int)Para[0]) {case Message_ReportProgress:if (ProgressChanged != null ){ProgressChanged.Invoke(this,(ProgressChangedEventArgs)Para[1]);}break;case Message_OnRunWorkerCompleted:if (RunWorkerCompleted != null)RunWorkerCompleted.Invoke(this,(RunWorkerCompletedEventArgs)Para[1]);break;}}});
}


    报告状态:

public void ReportProgress(int percentProgress, Object userState)
{if (ProgressChanged != null ){Message message = StarUIHander.handler.obtainMessage();message.what = HandlerQueue;message.obj = new Object[]{Message_ReportProgress,new ProgressChangedEventArgs(percentProgress,userState)};StarUIHander.handler.sendMessage(message);}
}


    创建线程执行:

public void RunWorkerAsync(Object userState)
{final BackgroundWorker m_worker = this;if (DoWork != null){IsBusy = true;try {final DoWorkEventArgs args = new DoWorkEventArgs(userState);new Thread(new Runnable(){@Overridepublic void run() {DoWork.Invoke(m_worker, args);IsBusy = false;if (RunWorkerCompleted != null) {Message message = StarUIHander.handler.obtainMessage();message.what = HandlerQueue;message.obj = new Object[]{Message_OnRunWorkerCompleted, new RunWorkerCompletedEventArgs(args.Result, null, args.Cancel)};StarUIHander.handler.sendMessage(message);}}}).start();}catch (Exception ex) {IsBusy = false;if (RunWorkerCompleted != null) {Message message = StarUIHander.handler.obtainMessage();message.what = HandlerQueue;message.obj = new Object[]{Message_OnRunWorkerCompleted, new RunWorkerCompletedEventArgs(false, ex, false)};StarUIHander.handler.sendMessage(message);}}}
}


     为了方面使用，将BackgroundWorker进行封装如下

    public static class StarCoreBackgroundWorker{private BackgroundWorker m_worker;public StarCoreBackgroundWorker(){m_worker = new BackgroundWorker();}public void CancelAsync(){m_worker.CancelAsync();}public void RunAsync(DoWorkEventHandler DoWork, Object userState, ProgressChangedEventHandler ProgressChanged, RunWorkerCompletedEventHandler RunWorkerCompleted){m_worker.DoWork = DoWork;m_worker.WorkerSupportsCancellation = true;m_worker.RunWorkerCompleted = RunWorkerCompleted;if (ProgressChanged != null){m_worker.ProgressChanged = ProgressChanged;m_worker.WorkerReportsProgress = true;}m_worker.RunWorkerAsync(userState);}public void ReportProgress(int percentProgress, Object userState){m_worker.ReportProgress(percentProgress, userState);}}

    使用方法：

StarBackgroundWorker myworker = new StarBackgroundWorker();
myworker.RunAsync(new DoWorkEventHandler() {public void Invoke(Object sender1, DoWorkEventArgs e1) {BackgroundWorker worker = sender1 as BackgroundWorker;//线程的主体}},null,new ProgressChangedEventHandler() {public void Invoke(Object sender1, ProgressChangedEventArgs e1) {//--在界面线程中执行，可以刷新界面}},new RunWorkerCompletedEventHandler() {public void Invoke(Object sender, RunWorkerCompletedEventArgs e) {//--在界面线程中处理，线程运行结束后的处理}});


3. ios中实现类似BackgroundWorker的功能

    ios创建线程可以使用NSThread，在界面线程中运行调用performSelectorOnMainThread函数；也可以使用GCD相关的函数，对多线程进行封装，可以实现类似c#的BackgroundWorker功能


a. 实现BackgroundWorker功能

    与android类似，在实现BackgroundWorker之前，参照c#的定义，同样需要实现一些相关的接口。有以下几个：
CancellationTokenSource, ProgressChangedEventArgs, DoWorkEventArgs，RunWorkerCompletedEventArgs，具体代码可参考附件


    定义接口:

typedef void(^ProgressChangedEventHandler)(id,ProgressChangedEventArgs*);
typedef void(^RunWorkerCompletedEventHandler)(id,RunWorkerCompletedEventArgs*);
typedef void(^DoWorkEventHandler)(id,DoWorkEventArgs*);

    实现BackgroundWorker

    上报状态:

-(void)ReportProgress:(uint)percentProgress userState:(id)userState
{if (ProgressChanged != nil || ProgressChangedSelector != nil ){dispatch_async(dispatch_get_main_queue(),^{@try{if( ProgressChangedSelector == nil )ProgressChanged(self,[ProgressChangedEventArgs initProgressChangedEventArgs:percentProgress UserState:userState]);else{IMP imp = [SelectorController methodForSelector:ProgressChangedSelector];void (*func)(id, SEL, id, ProgressChangedEventArgs* ) = (void *)imp;func(SelectorController, ProgressChangedSelector, self, [ProgressChangedEventArgs initProgressChangedEventArgs:percentProgress UserState:userState]);}}@catch(NSException* e){}});}
}

    异步执行 

-(void)RunWorkerAsync:(id)userState
{if (DoWork != nil || DoWorkSelector != nil){@try {DoWorkEventArgs* args = [DoWorkEventArgs initDoWorkEventArgs:userState];dispatch_async(dispatch_get_global_queue(0, 0),^{if( DoWork != nil )DoWork(self,args);else if(DoWorkSelector != nil ){IMP imp = [SelectorController methodForSelector:DoWorkSelector];void (*func)(id, SEL, id, DoWorkEventArgs* ) = (void *)imp;func(SelectorController, DoWorkSelector, self,args);}dispatch_async(dispatch_get_main_queue(),^{if (RunWorkerCompleted != nil)RunWorkerCompleted(self,[RunWorkerCompletedEventArgs initRunWorkerCompletedEventArgs:args.Result Cancelled:args.Cancel]);else if(RunWorkerCompletedSelector != nil){IMP imp = [SelectorController methodForSelector:RunWorkerCompletedSelector];void (*func)(id, SEL, id, RunWorkerCompletedEventArgs* ) = (void *)imp;func(SelectorController, RunWorkerCompletedSelector, self,[RunWorkerCompletedEventArgs initRunWorkerCompletedEventArgs:args.Result Cancelled:args.Cancel]);}});});}@catch(NSException* e){dispatch_async(dispatch_get_main_queue(),^{if (RunWorkerCompleted != nil)RunWorkerCompleted(self,[RunWorkerCompletedEventArgs initRunWorkerCompletedEventArgs:e]);else if( RunWorkerCompletedSelector != nil ){IMP imp = [SelectorController methodForSelector:RunWorkerCompletedSelector];void (*func)(id, SEL, id, RunWorkerCompletedEventArgs* ) = (void *)imp;func(SelectorController, RunWorkerCompletedSelector, self,[RunWorkerCompletedEventArgs initRunWorkerCompletedEventArgs:e]);}});}}
}
 
b. 为了方面使用，将BackgroundWorker进行封装如下

-(void)RunAsync:(DoWorkEventHandler)DoWork userState:(id)userState ProgressChanged:(ProgressChangedEventHandler)ProgressChanged RunWorkerCompleted:(RunWorkerCompletedEventHandler)RunWorkerCompleted
{m_worker.DoWork = DoWork;m_worker.RunWorkerCompleted = RunWorkerCompleted;if (ProgressChanged != nil){m_worker.ProgressChanged = ProgressChanged;}[m_worker RunWorkerAsync:userState];
}-(void)ReportProgress:(uint)percentProgress userState:(id)userState
{[m_worker ReportProgress:percentProgress userState:userState];
}

使用方法： 

StarBackgroundWorker* myworker = [StarBackgroundWorker initStarBackgroundWorker];[myworker RunAsync:^(id sender1, DoWorkEventArgs *e) {BackgroundWorker* worker = (BackgroundWorker*)sender1;} userState:nil ProgressChanged:^(id sender1, ProgressChangedEventArgs *e) {} RunWorkerCompleted:^(id sender1, RunWorkerCompletedEventArgs *e) {}}];


4. 结束语

    如果不考虑可移植性，可以直接使用android，ios，windows中定义的多线程方法开发应用，但由于不同平台采用的是不同语言，多线程实现接口和方式不同，会影响应用的逻辑结构，增加不同平台移植的工作量。基于线程执行过程，参考C#中的BackgroundWorker机制，在android和ios实现了类似的多线程机制，采用相同的框架结构，提供类似的接口，可以使多线程在不同平台具有相同的逻辑结构

    上面的代码不完整，具体请参考附件

下载附件







这篇关于android 和 ios中实现类似C#的BackgroundWorker接口的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/654343。

相关文章

基于 HTML5 Canvas 实现图片旋转与下载功能(完整代码展示)

基于 HTML5 Canvas 实现图片旋转与下载功能(完整代码展示)

《基于HTML5Canvas实现图片旋转与下载功能(完整代码展示)》本文将深入剖析一段基于HTML5Canvas的代码，该代码实现了图片的旋转（90度和180度）以及旋转后图片的下载... 目录一、引言二、html 结构分析三、css 样式分析四、JavaScript 功能实现一、引言在 Web 开发中，
阅读更多...
SpringBoot中使用Flux实现流式返回的方法小结

SpringBoot中使用Flux实现流式返回的方法小结

《SpringBoot中使用Flux实现流式返回的方法小结》文章介绍流式返回（StreamingResponse）在SpringBoot中通过Flux实现,优势包括提升用户体验、降低内存消耗、支持长连... 目录背景流式返回的核心概念与优势1. 提升用户体验2. 降低内存消耗3. 支持长连接与实时通信在Sp
阅读更多...
Conda虚拟环境的复制和迁移的四种方法实现

Conda虚拟环境的复制和迁移的四种方法实现

《Conda虚拟环境的复制和迁移的四种方法实现》本文主要介绍了Conda虚拟环境的复制和迁移的四种方法实现,包括requirements.txt,environment.yml,conda-pack,... 目录在本机复制Conda虚拟环境相同操作系统之间复制环境方法一：requirements.txt方法
阅读更多...
Spring Boot 实现 IP 限流的原理、实践与利弊解析

Spring Boot 实现 IP 限流的原理、实践与利弊解析

《SpringBoot实现IP限流的原理、实践与利弊解析》在SpringBoot中实现IP限流是一种简单而有效的方式来保障系统的稳定性和可用性,本文给大家介绍SpringBoot实现IP限... 目录一、引言二、IP 限流原理2.1 令牌桶算法2.2 漏桶算法三、使用场景3.1 防止恶意攻击3.2 控制资源
阅读更多...
springboot下载接口限速功能实现

springboot下载接口限速功能实现

《springboot下载接口限速功能实现》通过Redis统计并发数动态调整每个用户带宽,核心逻辑为每秒读取并发送限定数据量,防止单用户占用过多资源,确保整体下载均衡且高效,本文给大家介绍spring... 目录 一、整体目标 二、涉及的主要类/方法✅ 三、核心流程图解（简化） 四、关键代码详解1️⃣ 设置
阅读更多...
Nginx 配置跨域的实现及常见问题解决

Nginx 配置跨域的实现及常见问题解决

《Nginx配置跨域的实现及常见问题解决》本文主要介绍了Nginx配置跨域的实现及常见问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来... 目录1. 跨域1.1 同源策略1.2 跨域资源共享（CORS）2. Nginx 配置跨域的场景2.1
阅读更多...
Python中提取文件名扩展名的多种方法实现

Python中提取文件名扩展名的多种方法实现

《Python中提取文件名扩展名的多种方法实现》在Python编程中,经常会遇到需要从文件名中提取扩展名的场景,Python提供了多种方法来实现这一功能,不同方法适用于不同的场景和需求,包括os.pa... 目录技术背景实现步骤方法一：使用os.path.splitext方法二：使用pathlib模块方法三
阅读更多...
CSS实现元素撑满剩余空间的五种方法

CSS实现元素撑满剩余空间的五种方法

《CSS实现元素撑满剩余空间的五种方法》在日常开发中，我们经常需要让某个元素占据容器的剩余空间，本文将介绍5种不同的方法来实现这个需求，并分析各种方法的优缺点，感兴趣的朋友一起看看吧... css实现元素撑满剩余空间的5种方法 在日常开发中，我们经常需要让某个元素占据容器的剩余空间。这是一个常见的布局需求
阅读更多...
HTML5 getUserMedia API网页录音实现指南示例小结

HTML5 getUserMedia API网页录音实现指南示例小结

《HTML5getUserMediaAPI网页录音实现指南示例小结》本教程将指导你如何利用这一API，结合WebAudioAPI，实现网页录音功能,从获取音频流到处理和保存录音，整个过程将逐步... 目录1. html5 getUserMedia API简介1.1 API概念与历史1.2 功能与优势1.3
阅读更多...
Java实现删除文件中的指定内容

Java实现删除文件中的指定内容

《Java实现删除文件中的指定内容》在日常开发中,经常需要对文本文件进行批量处理,其中,删除文件中指定内容是最常见的需求之一,下面我们就来看看如何使用java实现删除文件中的指定内容吧... 目录1. 项目背景详细介绍2. 项目需求详细介绍2.1 功能需求2.2 非功能需求3. 相关技术详细介绍3.1 Ja
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2