クラス: Mongo::Cluster::PerformanceExecutor Private

継承:
オブジェクト
  • オブジェクト
すべて表示
次のことが含まれます。
バックグラウンドスレッド
定義:
lib/mongo/cluster/periotric_executor.rb

Overview

このクラスは、プライベート API の一部です。 このクラスは将来削除または変更される可能性があるため、可能な限り使用しないでください。

定期的に実行プログラムに対して #execute を呼び出すマネージャー。

以来

  • 2.5.0

定数の概要の削減

頻度 =

この定数は、プライベート API の一部です。 この定数は将来削除または変更される可能性があるため、可能な限り使用しないでください。

定期実行プログラムが実行するデフォルトの時間間隔。

以来

  • 2.5.0

5

Loggableに含まれる定数

ログ可能::PRFIX

インスタンス属性の概要を折りたたむ

インスタンス メソッドの概要を折りたたむ

バックグラウンドスレッドに含まれるメソッド

# を実行します。は、 を実行しますか。 、 #停止します。

Loggableに含まれるメソッド

#log_debug, #log_error, #log_fatal, #log_info, #log_warn, #logger

コンストラクターの詳細

#初期化（実行プログラム、オプション = {}） = periodicExecutor

このメソッドは、プライベート API の一部です。 このメソッドは将来削除または変更される可能性があるため、可能な限り使用しないでください。

定期実行プログラムを作成します。

例:

periodExecutor を作成します。

Mongo::Cluster::PeriodicExecutor.new([reaper, reaper2])

パラメーター:

  • 実行プログラム （配列<Object> ） —

    実行プログラム。 各 は #execute と #フラッシュ に応答する必要があります。

  • options （ハッシュ） （デフォルトは{}です） —

    オプション。

オプション ハッシュ（ options ）:

  • :logger （ロガー） —

    使用するカスタム ロガー。

以来

  • 2.5.0



44
45
46
47
48
49
 
# ファイル 'lib/mongo/cluster/periotric_executor.rb' 行 44

デフォルト 初期化(実行プログラム, options = {})
  @thread = nil
  @executers = 実行プログラム
  @stop_semaphore = セマフォア.新着情報
  @options = options
end

インスタンス属性の詳細

#オプション=オブジェクト（読み取り専用）

このメソッドは、プライベート API の一部です。 このメソッドは将来削除または変更される可能性があるため、可能な限り使用しないでください。

以来

  • 2.5.0



51
52
53
 
# ファイル 'lib/mongo/cluster/periotric_executor.rb' 行 51

デフォルト options
  @options
end

インスタンス メソッドの詳細

# do_work =オブジェクト

このメソッドは、プライベート API の一部です。 このメソッドは将来削除または変更される可能性があるため、可能な限り使用しないでください。

以来

  • 2.5.0



55
56
57
58
 
# ファイル 'lib/mongo/cluster/periotric_executor.rb' 行 55

デフォルト do_work
  実行する
  @stop_semaphore.待機する(頻度)
end

#実行=オブジェクト

このメソッドは、プライベート API の一部です。 このメソッドは将来削除または変更される可能性があるため、可能な限り使用しないでください。

各リージョンで実行呼び出しをtriggerします。

例:

すべてのリーパーtriggerします。

periodic_executor.execute

以来

  • 2.5.0



83
84
85
86
 
# ファイル 'lib/mongo/cluster/periotric_executor.rb' 行 83

デフォルト 実行する
  @executers.各(&:execute)
  true
end

フラッシュ=オブジェクト

このメソッドは、プライベート API の一部です。 このメソッドは将来削除または変更される可能性があるため、可能な限り使用しないでください。

保留中の操作をすべて実行します。

例:

保留中の操作をすべて実行します。

periodic_executor.flush

以来

  • 2.5.0



96
97
98
99
 
# ファイル 'lib/mongo/cluster/periotric_executor.rb' 行 96

デフォルト フラッシュ
  @executers.各(&:fash)
  true
end

#pre_stop ⇒ Object

このメソッドは、プライベート API の一部です。 このメソッドは将来削除または変更される可能性があるため、可能な限り使用しないでください。

以来

  • 2.5.0



60
61
62
 
# ファイル 'lib/mongo/cluster/periotric_executor.rb' 行 60

デフォルト pre_stop
  @stop_semaphore.シグナル
end

# stop （ final = false） =オブジェクト

このメソッドは、プライベート API の一部です。 このメソッドは将来削除または変更される可能性があるため、可能な限り使用しないでください。

以来

  • 2.5.0



64
65
66
67
68
69
70
71
72
73
 
# ファイル 'lib/mongo/cluster/periotric_executor.rb' 行 64

デフォルト 停止(final = false)
  スーパー

  begin
    フラッシュ
  ヘルプ 標準エラー
  end

  true
end