138 lines
3.9 KiB
TypeScript
138 lines
3.9 KiB
TypeScript
///<reference path="../../Utils/Collections/HashMap.ts"/>
|
||
module es {
|
||
export class SystemIndexManager {
|
||
public static INDEX = 0;
|
||
private static indices: HashMap<Function, number> = new HashMap<Function, number>();
|
||
|
||
public static getIndexFor(es: Class): number {
|
||
let index: number = SystemIndexManager.indices.get(es);
|
||
if (index === undefined) {
|
||
index = SystemIndexManager.INDEX++;
|
||
SystemIndexManager.indices.put(es, index);
|
||
}
|
||
return index;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 追踪实体的子集，但不实现任何排序或迭代。
|
||
*/
|
||
export abstract class EntitySystem {
|
||
private _entities: Entity[] = [];
|
||
private systemIndex_: number;
|
||
|
||
constructor(matcher?: Matcher) {
|
||
this._matcher = matcher ? matcher : Matcher.empty();
|
||
this.systemIndex_ = SystemIndexManager.getIndexFor(this.constructor);
|
||
this.initialize();
|
||
}
|
||
|
||
private _scene: Scene;
|
||
|
||
/**
|
||
* 这个系统所属的场景
|
||
*/
|
||
public get scene() {
|
||
return this._scene;
|
||
}
|
||
|
||
public set scene(value: Scene) {
|
||
this._scene = value;
|
||
this._entities = [];
|
||
}
|
||
|
||
private _matcher: Matcher;
|
||
|
||
public get matcher() {
|
||
return this._matcher;
|
||
}
|
||
|
||
private _startTime = 0;
|
||
private _endTime = 0;
|
||
private _useTime = 0;
|
||
/** 获取系统在当前帧所消耗的时间 仅在debug模式下生效 */
|
||
public get useTime() {
|
||
return this._useTime;
|
||
}
|
||
|
||
public initialize() {
|
||
|
||
}
|
||
|
||
public onChanged(entity: Entity) {
|
||
let contains = new es.List(this._entities).contains(entity);
|
||
let interest = this._matcher.isInterestedEntity(entity);
|
||
|
||
if (interest && !contains)
|
||
this.add(entity);
|
||
else if (!interest && contains)
|
||
this.remove(entity);
|
||
}
|
||
|
||
public add(entity: Entity) {
|
||
this._entities.push(entity);
|
||
this.onAdded(entity);
|
||
}
|
||
|
||
public onAdded(entity: Entity) { }
|
||
|
||
public remove(entity: Entity) {
|
||
new es.List(this._entities).remove(entity);
|
||
this.onRemoved(entity);
|
||
}
|
||
|
||
public onRemoved(entity: Entity) { }
|
||
|
||
public update() {
|
||
if (this.checkProcessing()) {
|
||
this.begin();
|
||
this.process(this._entities);
|
||
}
|
||
}
|
||
|
||
public lateUpdate() {
|
||
if (this.checkProcessing()) {
|
||
this.lateProcess(this._entities);
|
||
this.end();
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 在系统处理开始前调用
|
||
* 在下一个系统开始处理或新的处理回合开始之前（以先到者为准），使用此方法创建的任何实体都不会激活
|
||
*/
|
||
protected begin() {
|
||
if (!Core.Instance.debug)
|
||
return;
|
||
|
||
this._startTime = Date.now();
|
||
}
|
||
|
||
protected process(entities: Entity[]) { }
|
||
|
||
protected lateProcess(entities: Entity[]) { }
|
||
|
||
/**
|
||
* 系统处理完毕后调用
|
||
*/
|
||
protected end() {
|
||
if (!Core.Instance.debug)
|
||
return;
|
||
|
||
this._endTime = Date.now();
|
||
this._useTime = this._endTime - this._startTime;
|
||
}
|
||
|
||
/**
|
||
* 系统是否需要处理
|
||
*
|
||
* 在启用系统时有用，但仅偶尔需要处理
|
||
* 这只影响处理，不影响事件或订阅列表
|
||
* @returns 如果系统应该处理，则为true，如果不处理则为false。
|
||
*/
|
||
protected checkProcessing() {
|
||
return true;
|
||
}
|
||
}
|
||
}
|