status-im/open-bounty
2
0
Fork 0
mirror of https://github.com/status-im/open-bounty.git synced 2025-02-26 08:05:28 +00:00
Code Issues Projects Releases Wiki Activity

Wildfly workaround: reuse named scheduler thread between deployments

Browse Source
This commit is contained in:
kagel 2016-09-29 17:27:20 +03:00
parent e65fabf60e
commit e8375418d7
2 changed files with 43 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
project.clj
View File

@ -37,7 +37,6 @@
[org.postgresql/postgresql "9.4.1209"]
[org.webjars/webjars-locator-jboss-vfs "0.1.0"]
[luminus-immutant "0.2.2"]
[overtone/at-at "1.2.0"]
[clj.qrgen "0.4.0"]
[digest "1.4.4"]
[tentacles "0.5.1"]]
@ -61,7 +60,7 @@
:immutant {:war {:name "ROOT"
:destination "/opt/wildfly/standalone/deployments"
:context-path "/"}}
:ring {:destroy commiteth.scheduler/stop}
:ring {:destroy commiteth.scheduler/stop-scheduler}
;:npm {:dependencies ["primer-css" "latest"]}

58
src/clj/commiteth/scheduler.clj
View File

@ -3,13 +3,11 @@
[commiteth.eth.multisig-wallet :as wallet]
[commiteth.github.core :as github]
[commiteth.db.issues :as issues]
[commiteth.db.users :as users]
[commiteth.db.bounties :as bounties]
[overtone.at-at :refer [every mk-pool stop-and-reset-pool!]]
[clojure.tools.logging :as log]
[mount.core :as mount]))
(def pool (mk-pool))
[mount.core :as mount])
(:import [sun.misc ThreadGroupUtils]
[java.lang.management ManagementFactory]))
(defn update-issue-contract-address
"For each pending deployment:
@ -55,15 +53,43 @@
(issues/update-balance contract-address current-balance-hex)
(github/update-comment login repo comment-id issue-number current-balance-eth))))))
(mount/defstate scheduler
:start (do
(every (* 1 60 1000) update-issue-contract-address pool)
(every (* 1 60 1000) self-sign-bounty pool)
(every (* 1 60 1000) update-balance pool))
:stop (do
(log/info "Stopping scheduler pool")
(stop-and-reset-pool! pool)))
(def scheduler-thread-name "SCHEDULER_THREAD")
(defn stop []
(log/info "Stopping scheduler pool")
(stop-and-reset-pool! pool))
(defn get-thread-by-name
[name]
(let [root (ThreadGroupUtils/getRootThreadGroup)
threads-count (.getThreadCount (ManagementFactory/getThreadMXBean))
threads ^"[Ljava.lang.Thread;" (make-array Thread threads-count)]
(.enumerate root threads true)
(first (filter #(= name (.getName %)) threads))))
(defn every
[ms do-fn]
(.start (new Thread
(fn []
(while (not (.isInterrupted (Thread/currentThread)))
(do (try
(Thread/sleep ms)
(catch InterruptedException _
(.interrupt (Thread/currentThread))))
(do-fn))))
scheduler-thread-name)))
(defn stop-scheduler []
(when-let [scheduler (get-thread-by-name scheduler-thread-name)]
(log/debug "Stopping scheduler thread")
(.interrupt scheduler)))
(defn restart-scheduler [ms task]
(stop-scheduler)
(log/debug "Starting scheduler thread")
(while (get-thread-by-name scheduler-thread-name)
(Thread/sleep 1))
(every ms task))
(mount/defstate scheduler
:start (restart-scheduler 60000 (fn []
(update-issue-contract-address)
(self-sign-bounty)
(update-balance)))
:stop (stop-scheduler))