Jackpot pool (global / DB-shared). 重要: - addToPool() は高頻度で呼ばれるため、メインスレッドで DB を叩かない。

7Fields
2Constructors
9Methods
197Lines
Package
com.example.rankingplugin
Source
JackpotService.java
Kind
class
Roles
DB / 永続化非同期 / スケジューラ初期化 / ブートストラップサービス層
このクラスにも章立て解説を追加しています。 自動抽出の一覧だけでなく、下の『重点クラスの詳細解説』で読む順番・内部サブシステム・変更時の注意点まで追えます。 全クラス章立てガイドを見る

クラス説明

Jackpot pool (global / DB-shared).

重要:
- addToPool() は高頻度で呼ばれるため、メインスレッドで DB を叩かない。
- DB への反映は非同期でバッチ更新(UPDATE amount = amount + ?)。
- getAndReset() は「当選時」など低頻度なので DB をロックして原子的に取り出す。

責務と見どころ

重点クラスの詳細解説

Jackpot pool (global / DB-shared). 重要: - addToPool() は高頻度で呼ばれるため、メインスレッドで DB を叩かない。(root) パッケージの 小〜中規模クラスで、スケジューラを確認する起点です。全面展開版では、他の重点クラスと同じ章立てで読めるように補強しています。

最初に追う読む順番

  1. JackpotService
    依存オブジェクトと初期状態を束ね、このクラスが担当するランタイムの前提を固めます。
  2. shutdown
    後片付けと停止の出口です。残骸や再ログイン後の不整合はここを確認します。
  3. refreshCacheAsync
    refreshCacheAsync の主要処理を担当します。
  4. addToPool
    プールにポイントを追加(メインスレッドでDBを触らない)
  5. getPoolAmount
    現在のプール残高(基本はメモリキャッシュ)。
  6. flushPending
    DBに溜まった差分を反映(非同期タスクから呼ばれる前提)。
  7. refreshCacheSync
    DB への問い合わせまたは更新処理を担当します。
  8. getAndReset
    現在のプールを取り出して0にリセット(原子的)。

内部サブシステムの地図

起動・前提準備

初期テーブル、依存状態、定期処理の点灯など、このクラスが動き始める前提をまとめています。

主なメソッド
主なフィールド

入口 API と対象解決

外部から呼ばれる公開メソッドや、対象プレイヤー・対象データ・対象ワールドを引き当てる経路です。

主なメソッド
主なフィールド

非同期処理と定期実行

メインスレッド境界とバックグラウンド処理が交差します。重い処理やタイミング起因の不具合を追うときの要所です。

主なメソッド

代表フロー詳解

初期化と起動の流れ

  1. JackpotService
  2. getPoolAmount
  3. getAndReset

このクラスが前提状態を揃え、外部から利用可能な形まで立ち上がる流れです。新規依存の追加や起動失敗の調査はまずここから追います。

反映・保存・終了の流れ

  1. shutdown

結果を保持し、必要なら永続化し、最後に掃除まで行う出口です。画面更新だけ合って保存が壊れるケースや残骸が残るケースの確認に向きます。

変更時の注意点

外部接点

主な永続化テーブル

SQL 文字列から抽出できた主要テーブルです。スキーマ変更時の確認用です。

amountjackpot_pool

フィールド

VisibilityTypeName役割
privateDataSourcedsDB 接続元を保持します。
privateLongAdderpendingAddpendingAdd の状態を保持します。
privateAtomicLongdbPoolCacheキャッシュまたは直近計算結果を保持します。
privateAtomicBooleanflushRunningflushRunning の状態を保持します。
privateDbCircuitBreakerbreakerbreaker の状態を保持します。
privateBukkitTaskflushTask非同期処理やスケジューラ制御に使うハンドルです。
privateBukkitTaskrefreshTask非同期処理やスケジューラ制御に使うハンドルです。

コンストラクタ / 初期化

Signature説明主要呼び出し
public JackpotService(DataSource ds)依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。主要呼び出しなし
public JackpotService(JavaPlugin plugin, DataSource ds)依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。getConnection → createStatement → executeUpdate → jackpot_pool → onFailure → getLogger

メソッド索引

NameVisibilityKind説明
JackpotServicepublicコンストラクタ依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
JackpotServicepublicコンストラクタ依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
addToPoolpublicメソッドプールにポイントを追加(メインスレッドでDBを触らない)
getPoolAmountpublicメソッド現在のプール残高(基本はメモリキャッシュ)。
flushPendingprivateメソッドDBに溜まった差分を反映(非同期タスクから呼ばれる前提)。
refreshCacheSyncprivateメソッドDB への問い合わせまたは更新処理を担当します。
refreshCacheAsyncprivateメソッドrefreshCacheAsync の主要処理を担当します。
getAndResetpublicメソッド現在のプールを取り出して0にリセット(原子的)。
shutdownpublicメソッドプラグイン終了時に呼ぶ(未フラッシュ分をできるだけ反映)

メソッド詳細

JackpotService

コンストラクタpublic
public JackpotService(DataSource ds)

依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。

引数

throws

なし

主要な呼び出し順

目立つ内部呼び出しは抽出されませんでした。

JackpotService

コンストラクタpublic
public JackpotService(JavaPlugin plugin, DataSource ds)

依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。

引数

throws

なし

主要な呼び出し順

getConnectioncreateStatementexecuteUpdatejackpot_poolonFailuregetLoggerrefreshCacheSyncfind

addToPool

メソッドpublic
public void addToPool(long points)

プールにポイントを追加(メインスレッドでDBを触らない)

引数

throws

なし

主要な呼び出し順

addAndGet

getPoolAmount

メソッドpublic
public long getPoolAmount()

現在のプール残高(基本はメモリキャッシュ)。

引数

throws

なし

主要な呼び出し順

目立つ内部呼び出しは抽出されませんでした。

flushPending

メソッドprivate
private void flushPending()

DBに溜まった差分を反映(非同期タスクから呼ばれる前提)。

引数

throws

なし

主要な呼び出し順

isOfflinecompareAndSetsumThenResetgetConnectionprepareStatementsetLongexecuteUpdateonSuccess

refreshCacheSync

メソッドprivate
private void refreshCacheSync()

DB への問い合わせまたは更新処理を担当します。

引数

throws

なし

主要な呼び出し順

isOfflinegetConnectioncreateStatementexecuteQuerynextgetLongsumonSuccess

refreshCacheAsync

メソッドprivate
private void refreshCacheAsync()

refreshCacheAsync の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

refreshCacheSync

getAndReset

メソッドpublic
public long getAndReset()

現在のプールを取り出して0にリセット(原子的)。

引数

throws

なし

主要な呼び出し順

flushPendingisOfflinegetConnectionsetAutoCommitprepareStatementexecuteQuerynextgetLong

shutdown

メソッドpublic
public void shutdown()

プラグイン終了時に呼ぶ(未フラッシュ分をできるだけ反映)

引数

throws

なし

主要な呼び出し順

cancelflushPending

代表的な処理フロー

  1. 初期化フロー
    JackpotService → getConnection → createStatement → executeUpdate → jackpot_pool → onFailure
    依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
  2. shutdown フロー
    shutdown → cancel → flushPending
    プラグイン終了時に呼ぶ(未フラッシュ分をできるだけ反映)
  3. flushPending フロー
    flushPending → isOffline → compareAndSet → sumThenReset → getConnection → prepareStatement
    DBに溜まった差分を反映(非同期タスクから呼ばれる前提)。
  4. getAndReset フロー
    getAndReset → flushPending → isOffline → getConnection → setAutoCommit → prepareStatement
    現在のプールを取り出して0にリセット(原子的)。
  5. refreshCacheSync フロー
    refreshCacheSync → isOffline → getConnection → createStatement → executeQuery → next
    DB への問い合わせまたは更新処理を担当します。

外部との接点

Web ルート

このクラス内に目立つ Web ルート定義は見つかりませんでした。

SQL / テーブル

amountjackpot_pool

関連クラス

補足