kbmMW는 강력한 스케줄러 프레임워크를 제공하여 복잡한 태스크 스케줄링 및 멀티스레드 애플리케이션 개발을 지원합니다. 이 프레임워크는 여러 버전을 거치면서 유연한 멀티스레딩 도구로 발전했습니다. 본 문서에서는 kbmMW 스케줄러를 사용하여 태스크를 제어할 때 발생할 수 있는 일반적인 문제점과 그 해결 방안을 다룹니다.

문제 상황: 스케줄된 태스크 중지 시 애플리케이션 정지

특정 조건(예: 타임아웃)에서 실행 중인 스케줄된 태스크를 중지해야 하는 시나리오를 가정해 봅시다. 예를 들어, 위치 탐색 작업의 타임아웃을 모니터링하고, 타임아웃 발생 시 대기 UI를 숨기고 스케줄러 태스크를 종료해야 하는 경우입니다. 다음은 초기 구현 시도 코드입니다. 이 코드는 매 초 실행되며, 특정 조건에서 자신을 종료하도록 설계되었습니다.

procedure TMyDataModule.InitializeSchedulerMonitor;
begin
  // 1초마다 실행되는 모니터링 태스크 설정
  // 'Synchronized'를 사용하여 메인 스레드에서 태스크 로직을 직접 실행합니다.
  FMonitoringTask := Scheduler.Schedule(
    procedure(const TaskEvent: IkbmMWScheduledEvent)
    begin
      // ... (예: 위치 탐색 대기 UI 숨기기 등 메인 스레드 작업)
      OutputDebugString('모니터링 태스크 실행 중...');

      // AScheduledEvent.Terminate 호출 시 애플리케이션 정지 문제가 발생했습니다.
      TaskEvent.Terminate; // 태스크 즉시 종료
    end)
    .EverySecond(1)
    .Synchronized  // 메인 스레드에서 동기적으로 실행
    .NamedAs('monitorJob');
end;

위 코드에서 TaskEvent.Terminate를 호출했을 때 애플리케이션이 응답하지 않고 정지하는 문제가 발생했습니다. 이는 스케줄된 이벤트가 Synchronized 옵션으로 메인 스레드에서 직접 실행되고 있는 상황에서, 같은 스레드에서 이벤트를 종료하려 할 때 발생할 수 있는 교착 상태 또는 경합 조건 때문입니다.

해결 방안 1: SyncQueued 사용

Synchronized 대신 SyncQueued를 사용하면 이 문제를 해결할 수 있습니다. SyncQueued는 이벤트 실행 로직을 메인 스레드의 메시지 큐에 넣어 비동기적으로 처리하도록 합니다. 이렇게 하면 스케줄러 스레드에서 메인 스레드에 대한 블로킹 호출을 피할 수 있습니다.

procedure TMyDataModule.InitializeSchedulerMonitor;
begin
  // 1초마다 실행되는 모니터링 태스크 설정
  // 'SyncQueued'를 사용하여 메인 스레드 큐에 넣어 실행합니다.
  FMonitoringTask := Scheduler.Schedule(
    procedure(const TaskEvent: IkbmMWScheduledEvent)
    begin
      // ... (예: UI 업데이트 로직)
      OutputDebugString('모니터링 태스크 실행 중...');

      // SyncQueued와 함께 Terminate를 사용하면 정지 문제 없이 정상 작동합니다.
      TaskEvent.Terminate; // 태스크 즉시 종료
    end)
    .EverySecond(1)
    .SyncQueued // 메인 스레드 큐에 넣어 비동기 실행
    .NamedAs('monitorJob');
end;

또는, Synchronized나 SyncQueued 옵션을 사용하지 않고 태스크 자체는 스케줄러의 워커 스레드에서 실행되도록 하고, 메인 스레드와 상호작용이 필요한 부분만 명시적으로 TThread.Synchronize를 사용하는 방법도 있습니다. 이 경우 스케줄러의 기본 동작은 워커 스레드에서 실행됩니다.

procedure TMyDataModule.InitializeSchedulerMonitor;
begin
  // 1초마다 실행되는 모니터링 태스크 설정 (기본적으로 워커 스레드에서 실행)
  FMonitoringTask := Scheduler.Schedule(
    procedure(const TaskEvent: IkbmMWScheduledEvent)
    begin
      // 메인 스레드와 동기화가 필요한 UI 로직은 TThread.Synchronize 내에서 처리
      TThread.Synchronize(nil,
        procedure
        begin
          // ... (예: UI 업데이트 로직)
          OutputDebugString('메인 스레드 UI 업데이트 실행.');
        end);

      OutputDebugString('워커 스레드에서 모니터링 태스크 실행 중...');
      TaskEvent.Terminate; // 태스크 즉시 종료
    end)
    .EverySecond(1)
    .NamedAs('monitorJob'); // Synchronized/SyncQueued 옵션 명시 없음
end;

문제 상황 2: 종료된 태스크 재활성화 불가

AScheduledEvent.Terminate를 사용하여 태스크를 종료한 후, 나중에 동일한 이름으로 이 태스크를 재활성화하려는 시도가 실패하는 문제가 발견되었습니다. 예를 들어:

procedure TMyDataModule.AttemptReactivation;
begin
  var ExistingEvent: IkbmMWScheduledEvent;
  ExistingEvent := Scheduler.Events.GetByName('monitorJob');

  if Assigned(ExistingEvent) then
  begin
    // Terminate로 종료된 이벤트는 이 방식으로 재활성화되지 않습니다.
    ExistingEvent.Activate; // 이 호출은 아무런 효과가 없습니다.
    OutputDebugString('재활성화 시도 결과: ' + BoolToStr(ExistingEvent.Active));
  end
  else
    OutputDebugString('지정된 스케줄 이벤트를 찾을 수 없습니다.');
end;

Terminate 메서드는 단순히 태스크의 실행을 멈추는 것을 넘어, 스케줄러에서 해당 이벤트 인스턴스를 완전히 제거합니다. 따라서 Terminate된 이벤트는 더 이상 존재하지 않으므로 재활성화할 수 없습니다.

최종 해결 방안: Activate(False)를 이용한 일시 중지

태스크를 일시적으로 비활성화했다가 나중에 다시 활성화해야 하는 경우에는 AScheduledEvent.Terminate 대신 AScheduledEvent.Activate(False)를 사용해야 합니다. Activate(False)는 태스크를 스케줄러에서 제거하지 않고 단순히 비활성화 상태로 만듭니다. 이 상태에서는 Activate(True)를 호출하여 언제든지 태스크를 다시 시작할 수 있습니다.

procedure TMyDataModule.ConfigureTimeoutMonitor;
begin
  // 중복 생성을 방지하기 위해 기존 이벤트 확인
  if Scheduler.Events.GetByName('timeoutMonitor') <> nil then
  begin
    OutputDebugString('timeoutMonitor 스케줄 이벤트가 이미 존재합니다. 재설정합니다.');
    Scheduler.Events.GetByName('timeoutMonitor').Activate(False); // 기존 이벤트 비활성화
    // 필요하다면 Scheduler.Events.RemoveByName('timeoutMonitor')로 완전히 제거 후 재생성
    // 여기서는 단순히 비활성화 후 재사용 가능한 형태로 둡니다.
  end;

  // 1초마다 실행되는 타임아웃 감지 작업 생성 및 설정
  // UI 관련 로직을 안전하게 처리하기 위해 SyncQueued 사용
  Scheduler.Schedule(
    procedure(const EventContext: IkbmMWScheduledEvent)
    begin
      // ... (예: UI 업데이트, 타임아웃 감지 로직 실행)
      OutputDebugString('타임아웃 감지 로직 실행 및 일시 중지 처리.');

      // 작업의 즉각적인 종료 대신, 일시 중지하여 추후 재활성화 가능하게 합니다.
      EventContext.Activate(False); // 작업을 비활성화 (일시 중지)
    end)
    .EverySecond(1)
    .SyncQueued // 메인 스레드 큐에 넣어 실행
    .NamedAs('timeoutMonitor');
end;

이렇게 Activate(False)를 사용하여 태스크를 일시 중지하면, 나중에 필요한 시점에 다음 코드를 통해 쉽게 다시 활성화할 수 있습니다:

procedure TMyDataModule.ResumeTimeoutMonitor;
begin
  var TaskToResume: IkbmMWScheduledEvent;
  TaskToResume := Scheduler.Events.GetByName('timeoutMonitor');

  if Assigned(TaskToResume) then
  begin
    TaskToResume.Activate(True); // 비활성화된 태스크를 다시 활성화
    OutputDebugString('timeoutMonitor 태스크가 재활성화되었습니다.');
  end;
end;

이 방법을 통해 kbmMW 스케줄러의 태스크를 유연하게 제어하고, 필요한 경우 재활용할 수 있는 견고한 애플리케이션을 구축할 수 있습니다.