起動・前提準備
初期テーブル、依存状態、定期処理の点灯など、このクラスが動き始める前提をまとめています。
Jackpot pool (global / DB-shared). 重要: - addToPool() は高頻度で呼ばれるため、メインスレッドで DB を叩かない。
com.example.rankingpluginJackpotService.javaclassJackpot pool (global / DB-shared). 重要: - addToPool() は高頻度で呼ばれるため、メインスレッドで DB を叩かない。 - DB への反映は非同期でバッチ更新(UPDATE amount = amount + ?)。 - getAndReset() は「当選時」など低頻度なので DB をロックして原子的に取り出す。
Jackpot pool (global / DB-shared). 重要: - addToPool() は高頻度で呼ばれるため、メインスレッドで DB を叩かない。(root) パッケージの 小〜中規模クラスで、スケジューラを確認する起点です。全面展開版では、他の重点クラスと同じ章立てで読めるように補強しています。
JackpotServiceshutdownrefreshCacheAsyncaddToPoolgetPoolAmountflushPendingrefreshCacheSyncgetAndReset初期テーブル、依存状態、定期処理の点灯など、このクラスが動き始める前提をまとめています。
外部から呼ばれる公開メソッドや、対象プレイヤー・対象データ・対象ワールドを引き当てる経路です。
停止時やフロー終端で残る実体・タスク・キャッシュを戻す出口です。
DB テーブルとの境界です。スキーマ変更や保存漏れの切り分けはここから行います。
メインスレッド境界とバックグラウンド処理が交差します。重い処理やタイミング起因の不具合を追うときの要所です。
このクラスが前提状態を揃え、外部から利用可能な形まで立ち上がる流れです。新規依存の追加や起動失敗の調査はまずここから追います。
イベント受理、判定、状態更新、通知までの主経路です。体感不具合や想定外の分岐はこの流れのどこで止まるかを見ると切り分けやすいです。
結果を保持し、必要なら永続化し、最後に掃除まで行う出口です。画面更新だけ合って保存が壊れるケースや残骸が残るケースの確認に向きます。
SQL 文字列から抽出できた主要テーブルです。スキーマ変更時の確認用です。
| Signature | 説明 | 主要呼び出し |
|---|---|---|
public JackpotService(DataSource ds) | 依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。 | 主要呼び出しなし |
public JackpotService(JavaPlugin plugin, DataSource ds) | 依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。 | getConnection → createStatement → executeUpdate → jackpot_pool → onFailure → getLogger |
| Name | Visibility | Kind | 説明 |
|---|---|---|---|
| JackpotService | public | コンストラクタ | 依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。 |
| JackpotService | public | コンストラクタ | 依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。 |
| addToPool | public | メソッド | プールにポイントを追加(メインスレッドでDBを触らない) |
| getPoolAmount | public | メソッド | 現在のプール残高(基本はメモリキャッシュ)。 |
| flushPending | private | メソッド | DBに溜まった差分を反映(非同期タスクから呼ばれる前提)。 |
| refreshCacheSync | private | メソッド | DB への問い合わせまたは更新処理を担当します。 |
| refreshCacheAsync | private | メソッド | refreshCacheAsync の主要処理を担当します。 |
| getAndReset | public | メソッド | 現在のプールを取り出して0にリセット(原子的)。 |
| shutdown | public | メソッド | プラグイン終了時に呼ぶ(未フラッシュ分をできるだけ反映) |
public JackpotService(DataSource ds)依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
DataSource dsなし
public JackpotService(JavaPlugin plugin, DataSource ds)依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
JavaPlugin pluginDataSource dsなし
public void addToPool(long points)プールにポイントを追加(メインスレッドでDBを触らない)
long pointsなし
public long getPoolAmount()現在のプール残高(基本はメモリキャッシュ)。
なし
private void flushPending()DBに溜まった差分を反映(非同期タスクから呼ばれる前提)。
なし
private void refreshCacheSync()DB への問い合わせまたは更新処理を担当します。
なし
private void refreshCacheAsync()refreshCacheAsync の主要処理を担当します。
なし
public long getAndReset()現在のプールを取り出して0にリセット(原子的)。
なし
public void shutdown()プラグイン終了時に呼ぶ(未フラッシュ分をできるだけ反映)
なし
JackpotService → getConnection → createStatement → executeUpdate → jackpot_pool → onFailureshutdown → cancel → flushPendingflushPending → isOffline → compareAndSet → sumThenReset → getConnection → prepareStatementgetAndReset → flushPending → isOffline → getConnection → setAutoCommit → prepareStatementrefreshCacheSync → isOffline → getConnection → createStatement → executeQuery → next