using UnityEngine;
using System.Collections;
using System.Collections.Generic;
using System;
public enum CoroutinePriority
{
Low = 1, // 유휴
Medium = 2, // 움직임
High = 3, // 기절
Critical = 4 // 넉백
}
/// <summary>
/// 우선순위를 가진 코루틴을 관리하는 커스텀 코루틴 빌더.
/// </summary>
public class EntityCoroutineBuilder : MonoBehaviour, IEntityCoroutine
{
/// <summary>
/// 코루틴과 그 우선순위를 저장하는 클래스.
/// </summary>
private class CoroutineInfo
{
public CoroutinePriority Priority;
public IEnumerator Routine;
public bool IsActive;
// For handling CustomWaitForSeconds
public float WaitTimeRemaining;
// For handling WaitForFixedUpdate
public bool WaitForFixedUpdate;
public CoroutineInfo(CoroutinePriority priority, IEnumerator routine)
{
Priority = priority;
Routine = routine;
IsActive = true;
WaitTimeRemaining = 0f;
WaitForFixedUpdate = false;
}
}
public class CustomWaitForSeconds
{
public float seconds;
public CustomWaitForSeconds(float seconds)
{
this.seconds = seconds;
}
}
// 활성화된 코루틴 목록
private List<CoroutineInfo> activeCoroutines = new List<CoroutineInfo>();
/// <summary>
/// 우선순위를 지정하여 코루틴을 시작
/// </summary>
/// <param name="priority">코루틴의 우선순위.</param>
/// <param name="routine">실행할 코루틴.</param>
public void StartCoroutineWithPriority(CoroutinePriority priority, IEnumerator routine)
{
if (!gameObject.activeInHierarchy)
{
Debug.LogWarning("코루틴을 시작할 수 없습니다. EntityCoroutineBuilder가 비활성화 상태");
return;
}
// 더 높은 우선순위의 코루틴이 시작되면 낮은 우선순위의 코루틴을 중단
List<CoroutinePriority> lowerPriorities = new List<CoroutinePriority>();
foreach (var coroutine in activeCoroutines)
{
if (coroutine.Priority < priority && coroutine.IsActive)
{
lowerPriorities.Add(coroutine.Priority);
}
}
foreach (var lowerPriority in lowerPriorities)
{
Debug.Log($"Stopping coroutines with priority {lowerPriority} due to new coroutine with priority {priority}.");
StopCoroutinesByPriority(lowerPriority);
}
// 새로운 코루틴 추가
activeCoroutines.Add(new CoroutineInfo(priority, routine));
Debug.Log($"Starting coroutine with priority {priority}.");
}
/// <summary>
/// 특정 우선순위의 모든 코루틴을 중지
/// </summary>
/// <param name="priority">중지할 코루틴의 우선순위.</param>
public void StopCoroutinesByPriority(CoroutinePriority priority)
{
for (int i = activeCoroutines.Count - 1; i >= 0; i--)
{
var coroutine = activeCoroutines[i];
if (coroutine.Priority == priority && coroutine.IsActive)
{
coroutine.IsActive = false;
activeCoroutines.RemoveAt(i);
Debug.Log($"Stopped coroutine with priority {priority}.");
}
}
}
/// <summary>
/// 특정 우선순위의 코루틴이 실행 중인지 확인
/// </summary>
/// <param name="priority">확인할 우선순위.</param>
/// <returns>해당 우선순위의 코루틴이 실행 중이면 true, 아니면 false.</returns>
public bool IsCoroutineRunning(CoroutinePriority priority)
{
foreach (var coroutine in activeCoroutines)
{
if (coroutine.Priority == priority && coroutine.IsActive)
return true;
}
return false;
}
private void Update()
{
// 코루틴 목록을 복사하여 수정 중 오류 방지
var coroutinesToProcess = new List<CoroutineInfo>(activeCoroutines);
foreach (var coroutine in coroutinesToProcess)
{
if (!coroutine.IsActive)
continue;
if (coroutine.WaitForFixedUpdate)
continue; // FixedUpdate에서 처리
if (coroutine.WaitTimeRemaining > 0f)
{
coroutine.WaitTimeRemaining -= Time.deltaTime;
if (coroutine.WaitTimeRemaining > 0f)
continue;
}
try
{
bool hasNext = coroutine.Routine.MoveNext();
if (!hasNext)
{
// 코루틴이 완료되었으면 목록에서 제거
activeCoroutines.Remove(coroutine);
Debug.Log($"Coroutine Priority {coroutine.Priority} completed.");
}
else
{
HandleYieldInstruction(coroutine, coroutine.Routine.Current);
}
}
catch (Exception ex)
{
Debug.LogError($"코루틴 실행 중 예외 발생 (우선순위 {coroutine.Priority}): {ex.Message}\n{ex.StackTrace}");
activeCoroutines.Remove(coroutine);
}
}
}
private void FixedUpdate()
{
// 코루틴 목록을 복사하여 수정 중 오류 방지
var coroutinesToProcess = new List<CoroutineInfo>(activeCoroutines);
foreach (var coroutine in coroutinesToProcess)
{
if (!coroutine.IsActive)
continue;
if (!coroutine.WaitForFixedUpdate)
continue;
try
{
bool hasNext = coroutine.Routine.MoveNext();
if (!hasNext)
{
// 코루틴이 완료되었으면 목록에서 제거
activeCoroutines.Remove(coroutine);
Debug.Log($"Coroutine Priority {coroutine.Priority} completed.");
}
else
{
HandleYieldInstruction(coroutine, coroutine.Routine.Current);
}
}
catch (Exception ex)
{
Debug.LogError($"코루틴 실행 중 예외 발생 (우선순위 {coroutine.Priority}): {ex.Message}\n{ex.StackTrace}");
activeCoroutines.Remove(coroutine);
}
}
}
/// <summary>
/// YieldInstruction을 처리하는 메서드.
/// </summary>
/// <param name="coroutine">현재 코루틴 정보.</param>
/// <param name="yieldObj">현재 YieldInstruction 객체.</param>
private void HandleYieldInstruction(CoroutineInfo coroutine, object yieldObj)
{
if (yieldObj == null)
{
// 단순히 다음 프레임으로 넘어감
return;
}
if (yieldObj is CustomWaitForSeconds customWait)
{
coroutine.WaitTimeRemaining = customWait.seconds;
Debug.Log($"Coroutine Priority {coroutine.Priority}: Waiting for {customWait.seconds} seconds.");
}
else if (yieldObj is WaitForFixedUpdate)
{
coroutine.WaitForFixedUpdate = true;
Debug.Log($"Coroutine Priority {coroutine.Priority}: Waiting for FixedUpdate.");
}
else
{
Debug.LogWarning($"지원하지 않는 YieldInstruction: {yieldObj.GetType().Name}");
}
}
}
댓글 영역
획득법
① NFT 발행
작성한 게시물을 NFT로 발행하면 일주일 동안 사용할 수 있습니다. (최초 1회)
② NFT 구매
다른 이용자의 NFT를 구매하면 한 달 동안 사용할 수 있습니다. (구매 시마다 갱신)
사용법
디시콘에서지갑연결시 바로 사용 가능합니다.