Share via


アクターのライフ サイクル、自動ガベージ コレクション、および手動による削除

アクターは、いずれかのメソッドが最初に呼び出された時点でアクティブ化されます。 一定期間 (値は構成可能) 使用されていない場合、アクターは非アクティブ化されます (アクター ランタイムでガベージ コレクションが発生します)。 アクターとその状態はいつでも手動で削除できます。

アクターのアクティブ化

アクターは次のようにアクティブ化されます。

  • アクターが呼び出し時にまだアクティブになっていない場合は、新しいアクターが作成されます。
  • アクターの状態が保持されている場合は、状態が読み込まれます。
  • OnActivateAsync (C#) または onActivateAsync (Java) メソッド (アクターの実装でオーバーライドできる) が呼び出されます。
  • アクターはアクティブと見なされるようになります。

アクターの非アクティブ化

アクターは次のように非アクティブ化されます。

  • アクターは、一定期間使用されていない場合、アクティブ アクター テーブルから削除されます。
  • OnDeactivateAsync (C#) または onDeactivateAsync (Java) メソッド (アクターの実装でオーバーライドできる) が呼び出されます。 呼び出されると、アクターのタイマーをすべてクリアします。 状態の変更などのアクター操作は、このメソッドから呼び出さないようにしてください。

ヒント

Fabric アクター ランタイムはいくつかの アクターのアクティブ化と非アクティブ化に関するイベントを出力します。 これらは、診断やパフォーマンスの監視に役立ちます。

アクターのガベージ コレクション

アクターが非アクティブ化されると、アクター オブジェクトへの参照が解放され、共通言語ランタイム (CLR) または Java 仮想マシン (JVM) のガベージ コレクターによる通常のガベージ コレクションが可能になります。 ガベージ コレクションでクリーンアップされるのはアクター オブジェクトのみであり、アクターの状態マネージャーに格納されている状態は削除 されません 。 次にアクターがアクティブになると、新しいアクター オブジェクトが作成され、その状態が復元されます。

非アクティブ化やガベージ コレクションにおいて、次の状態は "使用中" と見なされます。

  • 呼び出しを受信する
  • IRemindable.ReceiveReminderAsync メソッドが呼び出されている (アクターがアラームを使用する場合にのみ適用可)

Note

アクターがタイマーを使用し、そのタイマーのコールバックが呼び出された場合、アクターは "使用中" とは 見なされません

非アクティブ化の詳細に入る前に、次の用語を定義しておくことが重要です。

  • スキャン間隔。 これは、アクター ランタイムがアクティブ アクター テーブルで、非アクティブ化およびガベージ コレクションが可能なアクターをスキャンする間隔です。 この既定値は 1 分です。
  • アイドル タイムアウト。 これは、非アクティブ化およびガベージ コレクションの前に、アクターが未使用 (アイドル) のままでいる必要がある時間です。 この既定値は 60 分です。

通常は、これらの既定値を変更する必要はありません。 ただし、必要であれば、ActorServiceSettingsの登録時に ActorServiceSettings を通じてこの間隔を変更できます。

public class Program
{
    public static void Main(string[] args)
    {
        ActorRuntime.RegisterActorAsync<MyActor>((context, actorType) =>
                new ActorService(context, actorType,
                    settings:
                        new ActorServiceSettings()
                        {
                            ActorGarbageCollectionSettings =
                                new ActorGarbageCollectionSettings(10, 2)
                        }))
            .GetAwaiter()
            .GetResult();
    }
}
public class Program
{
    public static void main(String[] args)
    {
        ActorRuntime.registerActorAsync(
                MyActor.class,
                (context, actorTypeInfo) -> new FabricActorService(context, actorTypeInfo),
                timeout);
    }
}

各アクティブ アクターについて、アクター ランタイムはアクターがアイドル (つまり、未使用) 状態だった時間を追跡します。 アクター ランタイムは、ScanIntervalInSeconds ごとにアクターをそれぞれチェックして、ガベージ コレクションおよびマークが可能かどうかを確認し、IdleTimeoutInSeconds の間アイドル状態だった場合はアクターを収集します。

アクターが使用されるたびに、そのアイドル時間は 0 にリセットされます。 その後、アクターをガベージ コレクトできるのは、再び IdleTimeoutInSecondsの間アイドル状態のままになった場合のみです。 アクター インターフェイス メソッドまたはアクター アラーム コールバックが実行された場合、アクターが使用されていると見なされることを思い出してください。 タイマー コールバックが実行された場合、アクターは使用されていると見なされ ません

次の図は、これらの概念を表す 1 つのアクターのライフ サイクルを示しています。

アイドル時間の例

この例では、このアクターの有効期間に対するアクター メソッドの呼び出し、アラームおよびタイマーの影響を示しています。 この例では次の点に注意する必要があります。

  • ScanInterval は 5、IdleTimeout は 10 にそれぞれ設定されます。 (概念の説明のみが目的であるため、ここでは単位は重要ではありません)。
  • ガベージ コレクションの対象となるアクターのスキャンは、5 のスキャン間隔で定義されると、T=0、5、10、15、20、25 で行われます。
  • 定期的なタイマーは T=4、8、12、16、20、24 で開始され、そのコールバックが実行されます。 アクターのアイドル時間に影響はありません。
  • T=7 のアクター メソッド呼び出しは、アイドル時間を 0 にリセットし、アクターのガベージ コレクションを遅らせます。
  • アクター アラームのコールバックは T=14 で実行され、アクターのガベージ コレクションをさらに遅らせます。
  • T=25 のガベージ コレクションのスキャン中に、アクターのアイドル時間は最終的に 10 のアイドル タイムアウトを超え、アクターはガベージ コレクトされます。

メソッドの実行にどれだけ時間がかかっても、いずれかのメソッドが実行中のアクターがガベージ コレクションの対象となることはありません。 前述のように、アクター インターフェイス メソッドとアラームのコールバックを実行すると、アクターのアイドル時間が 0 にリセットされるため、ガベージ コレクションが行われなくなります。 タイマー コールバックの実行では、アイドル時間は 0 にリセットされません。 ただし、タイマー コールバックの実行が完了するまで、アクターのガベージ コレクションは遅延されます。

アクターとその状態を手動で削除する

非アクティブ化されたアクターのガベージ コレクションではアクター オブジェクトのみがクリーンアップされ、アクターの状態マネージャーに格納されているデータは削除されません。 アクターが再アクティブ化されると、そのデータは状態マネージャーを介して再び利用可能になります。 状態マネージャーにデータを格納したアクターが非アクティブ化され、その後も再アクティブ化されなかった場合は、そのデータをクリーンアップする必要が生じる場合があります。 アクターを削除する方法の例については、「アクターとその状態の削除」を参照してください。

次のステップ