109 lines
2.9 KiB
C#
109 lines
2.9 KiB
C#
using System;
|
|
using System.Collections;
|
|
using System.Collections.Generic;
|
|
using System.Timers;
|
|
using Cysharp.Threading.Tasks;
|
|
using UnityEngine;
|
|
|
|
namespace BITKit
|
|
{
|
|
[Serializable]
|
|
public sealed class GameTick:ITicker
|
|
{
|
|
|
|
public ulong TickCount => GameTickService.TickCount;
|
|
|
|
public void Add(Action action)=>GameTickService.Add(action);
|
|
|
|
public void Add(Action<float> action)=>GameTickService.Add(action);
|
|
|
|
public void Remove(Action<float> action)=>GameTickService.Remove(action);
|
|
}
|
|
public class GameTickService : MonoBehaviour,ITicker
|
|
{
|
|
[RuntimeInitializeOnLoadMethod]
|
|
private static void Reload()
|
|
{
|
|
_ActionQueue.Clear();
|
|
_AddActionQueue.Clear();
|
|
_RemoveQueue.Clear();
|
|
TickCount = ulong.MinValue;
|
|
}
|
|
private static readonly Queue<Action> _ActionQueue = new();
|
|
private static readonly Queue<Action<float>> _AddActionQueue = new();
|
|
private static readonly Queue<Action<float>> _RemoveQueue = new();
|
|
private static event Action<float> _TickEvents;
|
|
public static void Add(Action action)=>_ActionQueue.Enqueue(action);
|
|
public static void Add(Action<float> action)=>_AddActionQueue.Enqueue(action);
|
|
public static void Remove(Action<float> action)=>_RemoveQueue.Enqueue(action);
|
|
public static ulong TickCount { get; private set; }
|
|
|
|
ulong ITicker.TickCount => TickCount;
|
|
|
|
void ITicker.Add(Action action)=>Add(action);
|
|
void ITicker.Add(Action<float> action)=>Add(action);
|
|
void ITicker.Remove(Action<float> action)=>Remove(action);
|
|
[SerializeField] private int tickRate = 32;
|
|
[SerializeField] private bool isMainThread;
|
|
[SerializeField] private bool isConcurrent;
|
|
private readonly Timer _timer = new();
|
|
private float _deltaTime;
|
|
private double _lastTime;
|
|
|
|
private void Start()
|
|
{
|
|
tickRate = Mathf.Clamp(tickRate, 1, 128);
|
|
|
|
_deltaTime = 1f / tickRate;
|
|
|
|
_timer.Elapsed += Tick;
|
|
_timer.AutoReset = isConcurrent;
|
|
_timer.Interval = TimeSpan.FromSeconds(_deltaTime).TotalMilliseconds;
|
|
_timer.Start();
|
|
destroyCancellationToken.Register(() =>
|
|
{
|
|
_timer.Stop();
|
|
_timer.Dispose();
|
|
});
|
|
}
|
|
private async void Tick(object sender, ElapsedEventArgs e)
|
|
{
|
|
TickCount++;
|
|
try
|
|
{
|
|
var delta = BITApp.Time.TimeAsDouble - _lastTime;
|
|
_lastTime = BITApp.Time.TimeAsDouble;
|
|
if (isMainThread) await UniTask.SwitchToMainThread(destroyCancellationToken);
|
|
while (_ActionQueue.TryDequeue(out var action))
|
|
{
|
|
action?.Invoke();
|
|
}
|
|
_TickEvents?.Invoke((float)delta);
|
|
}
|
|
catch (OperationCanceledException)
|
|
{
|
|
return;
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
BIT4Log.LogException(exception);
|
|
}
|
|
|
|
while (_AddActionQueue.TryDequeue(out var action))
|
|
{
|
|
_TickEvents += action;
|
|
}
|
|
while (_RemoveQueue.TryDequeue(out var action))
|
|
{
|
|
_TickEvents -= action;
|
|
}
|
|
|
|
if (isConcurrent is false && destroyCancellationToken.IsCancellationRequested is false)
|
|
{
|
|
_timer.Start();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|