TypeScript之多方法執行方案
一， 情景
①，A，B，C，D四個方法都執行完畢以後再執行E方法
②，A，B，C，D四個方法有其中任意一個執行完畢後再執行E方法異步
注意： A、B，C，D 能夠是普通方法， 也能夠是異步方法 ，能夠帶參數， 也能夠沒有參數async
二，解決方案
①，BaseMultiFunctionExecute.ts (對方法執行基類)ide
/**
* 多方法執行基類
* @author Husz
*/
abstract class BaseMultiFunctionExecute<T extends IMultiFunctionData>{
protected _list: Array<T>;
protected _callback: (tag: string, sender: any, ...arg) => void;
protected _mgrCb: (tag: string, sender: any, ...arg) => void;
protected _isExeing: boolean = false;//是否正在處理中
protected _curIndex: number;
protected _inPool: boolean = false;
protected _tag: string;
/**
* 是否在對象池
*/
public set InPool(value: boolean) {
this._inPool = value;
}
/**
* 是否在對象池
*/
public get InPool(): boolean {
return this._inPool;
}
public constructor(tag: string, list: Array<{ exeFun: Function, sender: any, isPromise?: boolean, exeParams?: Array<any> }>, callback: (tag: string, sender: any, ...arg) => void, mgrCb: (tag: string, sender: any, ...arg) => void) {
this._mgrCb = mgrCb;
this.resetData(tag, list, callback);
}
/**
* 獲取類型
*/
public abstract getType(): Ty2MultiFunctions;
/**
* 重置數據
*/
public resetData(tag: string, list: Array<{ exeFun: Function, sender: any, isPromise?: boolean, exeParams?: Array<any> }>, callback: (tag: string, sender: any, ...arg) => void): void {
if (this._inPool) return;
this._tag = tag;
this._list = this.getList(list);
this._callback = callback;
}
/**
* 獲取list數據
*/
protected getList(list: Array<{ exeFun: Function, sender: any, isPromise?: boolean, exeParams?: Array<any> }>): Array<T> {
if (list == null || list.length == 0) return [];
let cell: { exeFun: Function, sender: any, isPromise?: boolean, exeParams?: Array<any> };
let bc: Array<T> = [];
for (let i: number = 0, j: number = list.length; i < j; i++) {
cell = list[i];
bc.push(<T><any>{
exeFun: cell.exeFun,
sender: cell.sender,
isPromise: cell.isPromise != null ? cell.isPromise : false,
isSucc: false,
exeParams: cell.exeParams == null || cell.exeParams.length < 0 ? null : cell.exeParams,
complete: false
});
}
return bc;
}
/**
* @return 是否添加成功
*/
public addItem(cell: { exeFun: Function, sender: any, isPromise?: boolean, exeParams?: Array<any> }): boolean {
if (this._isExeing || !cell || this._inPool) return false;
let data: T = <T><any>{
exeFun: cell.exeFun,
sender: cell.sender,
isPromise: cell.isPromise != null ? cell.isPromise : false,
isSucc: false,
exeParams: cell.exeParams == null || cell.exeParams.length < 0 ? null : cell.exeParams,
complete: false
};
if (this._list) {
this._list.push(data);
} else {
this._list = [data];
}
return true;
}
/**
* 開始處理數據(入口)
*/
public async startExe(): Promise<void> {
return new Promise<void>(resolve => {
if( this._isExeing || this._inPool){
resolve();
return;
}
if (this._list == null || this._list.length == 0 ) {
this._callback(`exe_complete`, this, this._tag);
this._mgrCb(`over`, this, this._tag);
resolve();
} else {
this.exeFunctions();
resolve();
}
});
}
/**
* 執行方法
*/
protected exeFunctions(): void {
this._isExeing = true;
this._curIndex = 0;
}
/**
* 檢測是否已經作完
* @param data
*/
protected checkOver(data: T, isSucc: boolean): void {
data.complete = true;
data.isSucc = isSucc;
this.addCopletaTag();
}
/**
* 處理完成計數
*/
protected addCopletaTag(): void {
this._curIndex++;
if (this._curIndex >= this._list.length) {
this._callback(`exe_complete`, this, this._tag);
this._mgrCb(`over`, this);
}
}
/**
* 清理
*/
public clear(): void {
this._isExeing = false;
this._list = null;
this._inPool = true;
}
/**
* @return { complete: 是否執行完畢, isSucc: 是否執行成功 }
*/
public isFunComplete(exeFun: Function): { complete: boolean, isSucc: boolean } {
if (!this._list || this._list.length == 0 || this._inPool) return { complete: false, isSucc: false };
let data: T;
for (let i: number = 0, j: number = this._list.length; i < j; i++) {
data = this._list[i];
if (data.exeFun == exeFun) {
if (data.complete == null && data.complete == false) {
return { complete: false, isSucc: false };
} else {
return { complete: true, isSucc: data.isSucc }
}
}
}
return { complete: false, isSucc: false };
}
/**
* 銷燬
*/
public destroy(): void {
this._callback = null;
this._list = null;
this._mgrCb = null;
}
}
/**
* 多方法執行單元數據
* @author Husz
*/
interface IMultiFunctionData {
exeFun: Function;
sender: any;
complete?: boolean;
exeParams?: Array<any>;
isPromise: boolean;//是不是異步方法
isSucc?: boolean;//是否執行成功
}
②，TogetherExecute.ts (所有執行完畢後執行E 子類）this
/**
* 所有執行
* @author Husz
*/
class TogetherExecute extends BaseMultiFunctionExecute<IMultiFunctionData>{
/**
* @inheritDoc
*/
protected exeFunctions(): void {
super.exeFunctions();
this.stepDoFunctions(this._curIndex);
}
/**
* @inheritDoc
*/
public getType(): Ty2MultiFunctions {
return Ty2MultiFunctions.___TOGETHER___;
}
/**
* 處理異步方法
*/
private doPomise(data: IMultiFunctionData): void {
if (data.sender != null) {
data.exeFun.bind(data.sender);
}
if (data.exeParams != null && data.exeParams.length > 0) {
data.exeFun(...data.exeParams).then(() => {
this.checkOver(data, true);
}).catch(() => {
this.checkOver(data, false);
});
} else {
data.exeFun().then(() => {
this.checkOver(data, true);
}).catch(() => {
this.checkOver(data, false);
});
}
}
/**
* 分步執行方法
*/
private stepDoFunctions: (index: number) => void = (index) => {
if (index < this._list.length) {
let data: IMultiFunctionData = this._list[index];
if (data.isPromise) {
this.doPomise(data);
} else {
if (data.sender) {
if (data.exeParams != null && data.exeParams.length > 0) {
data.exeFun.call(data.sender, ...data.exeParams);
} else {
data.exeFun.call(data.sender);
}
} else {
if (data.exeParams != null && data.exeParams.length > 0) {
data.exeFun(...data.exeParams);
} else {
data.exeFun();
}
}
this.checkOver(data, true);
}
index++;
this.stepDoFunctions(index);
}
};
}
③，OtherExecute.ts (任意方法執行完畢執行E 子類)3d
/**
* 其中一個完成
* @author Husz
*/
class OtherExecute extends BaseMultiFunctionExecute<IMultiFunctionData>{
/**
* @inheritDoc
*/
protected addCopletaTag(): void {
this._curIndex++;
if (this._curIndex == 1) {
this._callback(`exe_complete`, this, this._tag);
}
if (this._curIndex >= this._list.length) {
this._mgrCb(`over`, this); // 通知管理器處理結束
// this._callback( `all_complete` , this );
}
}
/**
* @inheritDoc
*/
public getType(): Ty2MultiFunctions {
return Ty2MultiFunctions.___OTHER___;
}
/**
* @inheritDoc
*/
protected exeFunctions(): void {
super.exeFunctions();
this.stepDoFunctions(this._curIndex);
}
/**
* 處理異步方法
*/
private doPomise(data: IMultiFunctionData): void {
if (data.sender != null) {
data.exeFun.bind(data.sender);
}
if (data.exeParams != null && data.exeParams.length > 0) {
data.exeFun(...data.exeParams).then(() => {
this.checkOver(data, true);
}).catch(() => {
this.checkOver(data, false);
});
} else {
data.exeFun().then(() => {
this.checkOver(data, true);
}).catch(() => {
this.checkOver(data, false);
});
}
}
/**
* 分步執行方法
*/
private stepDoFunctions: (index: number) => void = (index) => {
if (index < this._list.length) {
let data: IMultiFunctionData = this._list[index];
if (data.isPromise) {
this.doPomise(data);
} else {
if (data.sender) {
if (data.exeParams != null && data.exeParams.length > 0) {
data.exeFun.call(data.sender, ...data.exeParams);
} else {
data.exeFun.call(data.sender);
}
} else {
if (data.exeParams != null && data.exeParams.length > 0) {
data.exeFun(...data.exeParams);
} else {
data.exeFun();
}
}
this.checkOver(data, true);
}
this.stepDoFunctions(++index);
}
};
}
④，MultiFunctionsMgr.ts (多方法執行管理器)code
/**
* 多方法執行管理器
* @author Husz
*/
class MultiFunctionsMgr {
private static _instance: MultiFunctionsMgr;
public static get Instance(): MultiFunctionsMgr {
if (!MultiFunctionsMgr._instance)
MultiFunctionsMgr._instance = new MultiFunctionsMgr();
return MultiFunctionsMgr._instance;
}
private _list: Map<Ty2MultiFunctions, PoolObject<BaseMultiFunctionExecute<any>>>;
private constructor() {
this._list = new Map<Ty2MultiFunctions, PoolObject<BaseMultiFunctionExecute<any>>>();
}
private createExe(tag: string, ty: Ty2MultiFunctions, list: Array<{ exeFun: Function, sender: any, isPromise?: boolean, exeParams?: Array<any> }>, callback: (tag: string, sender: any, ...arg) => void): BaseMultiFunctionExecute<any> {
switch (ty) {
case Ty2MultiFunctions.___TOGETHER___:
return new TogetherExecute(tag, list, callback, this.onStandardCallback);
case Ty2MultiFunctions.___OTHER___:
return new OtherExecute(tag, list, callback, this.onStandardCallback);
}
}
/**
* 獲取執行句柄
*/
public getExeFun(tag: string, ty: Ty2MultiFunctions, list: Array<{ exeFun: Function, sender: any, isPromise?: boolean, exeParams?: Array<any> }>, callback: (tag: string, sender: any, ...arg) => void): BaseMultiFunctionExecute<any> {
let cell: BaseMultiFunctionExecute<any>;
if (this._list.has(ty)) {
let pool: PoolObject<BaseMultiFunctionExecute<any>>;
pool = this._list[ty];
cell = pool.Cell;
if (!cell) {
cell = this.createExe(tag, ty, list, callback);
} else {
cell.InPool = false;//從對象池中提取出來了
cell.resetData(tag, list, callback);
}
} else {
cell = this.createExe(tag, ty, list, callback);
}
return cell;
}
/**
* 標準回調
*/
private onStandardCallback: (tag: string, sender: any, ...arg) => void = (tag, sender, ...arg) => {
switch (tag) {
case `over`:
(sender as BaseMultiFunctionExecute<any>).clear();
let ty: Ty2MultiFunctions = (sender as BaseMultiFunctionExecute<any>).getType();
let pool: PoolObject<BaseMultiFunctionExecute<any>>;
if (this._list.has(ty)) {
pool = this._list[ty];
if (!pool.push(sender)) {
(sender as BaseMultiFunctionExecute<any>).destroy();
}
} else {
pool = new PoolObject<BaseMultiFunctionExecute<any>>(2);
pool.push(sender);
this._list.set(ty, pool);
}
break;
}
};
}
/**
* 執行類型
* @author Husz
*/
enum Ty2MultiFunctions {
___TOGETHER___ = 1,
___OTHER___ = 2
}
三，調用方案
①，回調對象
private onStandardCallback: ( tag: string, sender: any,...arg ) => void = (tag, sender, ...arg) => {
switch (tag) {
case `exe_complete`:
if( arg[0] == `Aonaufly` ){
console.log(`lkkkkkk : -> `);
}
break;
}
};
②，A，B，C，D方法blog
private doA( ): void{
console.log(`do a`);
}
private doB( a: number , b: number ): void{
console.log( `do b ${ a + b }` );
}
private async doC(): Promise<void>{
return new Promise<void>( resolve => {
egret.setTimeout( () => {
console.log(`do c`);
resolve();
} , this, 2000 );
} );
}
private async doD( a: number , b: number ): Promise<void>{
return new Promise<void>( resolve => {
egret.setTimeout( () => {
console.log(`do d ${a + b}`);
resolve();
} , this, 2000 );
} );
}
③調用ip
this.a = MultiFunctionsMgr.Instance.getExeFun(
`Aonaufly`,
Ty2MultiFunctions.___TOGETHER___,
[
{
exeFun: this.doA,
sender: this,
isPromise: false,
exeParams: null
},
{
exeFun: this.doB,
sender: this,
isPromise: false,
exeParams: [1,2]
},
{
exeFun: this.doC,
sender: this,
isPromise: true,
exeParams: null
},
{
exeFun: this.doD,
sender: this,
isPromise: true,
exeParams: [3,4]
}
],
this.onStandardCallback
);
this.a.startExe();
四，執行結果：
相關文章
- 1. 異步執行方法方案
- 2. jmeter 多線程執行操作方法
- 3. RDD之collect方法執行的過程
- 4. 【PUPPETEER】初探之執行JavaScript方法（六）
- 5. vue mounted方法執行屢次問題的解決方案
- 6. redis的多命令執行方法之一-pipeling
- 7. java多線程執行方法之ThreadPoolExecutor與Executors的比較
- 8. RN 集成 TypeScript方案
- 9. js延時執行方法
- 10. iOS 延遲執行方法
- 更多相關文章...
- • Redis主從複製的配置方法和執行過程 - Redis教程
- • ASP Contents.Remove 方法 - ASP 教程
- • PHP Ajax 跨域問題最佳解決方案
- • 常用的分佈式事務解決方案
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. 安裝cuda+cuDNN
- 2. GitHub的使用說明
- 3. phpDocumentor使用教程【安裝PHPDocumentor】
- 4. yarn run build報錯Component is not found in path 「npm/taro-ui/dist/weapp/components/rate/index「
- 5. 精講Haproxy搭建Web集羣
- 6. 安全測試基礎之MySQL
- 7. C/C++編程筆記：C語言中的複雜聲明分析，用實例帶你完全讀懂
- 8. Python3教程(1)----搭建Python環境
- 9. 李宏毅機器學習課程筆記2：Classification、Logistic Regression、Brief Introduction of Deep Learning
- 10. 阿里雲ECS配置速記
歡迎關注本站公眾號,獲取更多信息
