FDK24/カウンタ/定間隔進行.cs

   1 using System;
   2 using System.Collections.Generic;
   3
   4 namespace FDK.カウンタ
   5 {
   6         /// <summary>
   7         ///             一定間隔ごとの進行処理を実現するクラス。
   8         /// </summary>
   9         /// <remarks>
  10         ///             <para> 例えば、
  11         ///                     <code>
  12         ///                       var cf = new C定間隔進行();
  13         ///                       cf.経過時間の分だけ進行する( 400, 定間隔処理 );
  14         ///                     </code>
  15         ///                     と記述した場合、400ms ごとに 定間隔処理() が実行されるようになる。
  16         ///             </para>
  17         ///             <para>
  18         ///                     ただし、この動作は「経過時間の分だけ進行する()」メソッドを呼び出した時に、定間隔処理() を「必要な回数だけ反復実行」する仕様である。
  19         ///                     例えば、先述の例において、メソッドの呼び出し時点で、前回の同メソッド（またはコンストラクタ）の呼び出しから 900ms が経過していたとすると、
  20         ///                     定間隔処理() は 900÷400 = 2回実行され、残りの 100ms が経過時間として次回に繰り越される。
  21         ///                     （一回の処理に時間がかかった場合にも定間隔処理が並列実行されるわけではない。）
  22         ///             </para>
  23         ///             <para>
  24         ///                     なお、定間隔処理にラムダ式を使用する場合は、キャプチャ変数のライフサイクル（実行される時点でまだ存在しているか否か）に留意し、弱い参照 の利用も検討すること。
  25         ///             </para>
  26         /// </remarks>
  27         public class 定間隔進行
  28         {
  29                 /// <summary>
  30                 ///             初期化し、同時に間隔の計測も開始する。
  31                 /// </summary>
  32                 public 定間隔進行()
  33                 {
  34                         this.経過時間の計測を開始する();
  35                 }
  36
  37                 public void 経過時間の計測を開始する()
  38                 {
  39                         lock( this._スレッド間同期 )
  40                         {
  41                                 this._タイマ.リセットする();
  42                         }
  43                 }
  44
  45                 public void 経過時間の計測を一時停止する()
  46                 {
  47                         lock( this._スレッド間同期 )
  48                         {
  49                                 this._タイマ.一時停止する();
  50                         }
  51                 }
  52
  53                 public void 経過時間の計測を再開する()
  54                 {
  55                         lock( this._スレッド間同期 )
  56                         {
  57                                 this._タイマ.再開する();
  58                         }
  59                 }
  60
  61                 public void 経過時間の分だけ進行する( long 間隔ms, Action 定間隔処理 )
  62                 {
  63                         lock( this._スレッド間同期 )
  64                         {
  65                                 // 現在時刻を取得する。
  66                                 this._タイマ.現在のカウントをキャプチャする();
  67                                 long 現在時刻ms = this._タイマ.現在のキャプチャカウント100ns / 10000;
  68
  69                                 // 初めての進行の場合、前回時刻を初期化する。
  70                                 if( this._前回の進行時刻ms == QPCTimer.未使用 )
  71                                         this._前回の進行時刻ms = 現在時刻ms;
  72
  73                                 // （ないと思うが）タイマが一回りしてしまった時のための保護。正常動作を保証するものではない。
  74                                 if( this._前回の進行時刻ms > 現在時刻ms )
  75                                         this._前回の進行時刻ms = 現在時刻ms;
  76
  77                                 // 経過時間における回数だけ、処理を実行する。
  78                                 while( ( 現在時刻ms - this._前回の進行時刻ms ) >= 間隔ms )
  79                                 {
  80                                         定間隔処理();
  81                                         this._前回の進行時刻ms += 間隔ms;
  82                                 }
  83                         }
  84                 }
  85
  86                 private long _前回の進行時刻ms = QPCTimer.未使用;
  87
  88                 private readonly QPCTimer _タイマ = new QPCTimer();
  89
  90                 private readonly object _スレッド間同期 = new object();
  91         }
  92 }