diff --git a/include/modules/image.hpp b/include/modules/image.hpp index 035dc4df..5b4ac818 100644 --- a/include/modules/image.hpp +++ b/include/modules/image.hpp @@ -19,6 +19,9 @@ namespace image { class IStrategy { public: virtual ~IStrategy() = default; + // Runs on the worker thread before update(). Use it for blocking work (e.g. + // spawning a user script) so the GTK main loop isn't stalled. Default no-op. + virtual void fetch() {} virtual void update() = 0; }; @@ -46,6 +49,7 @@ class MultipleImageStrategy : public IStrategy { public: MultipleImageStrategy(const std::string&, const Json::Value&, const std::string&, Gtk::EventBox&); ~MultipleImageStrategy() override = default; + void fetch() override; void update() override; private: @@ -67,6 +71,8 @@ class MultipleImageStrategy : public IStrategy { int size_; Gtk::Box box_; std::vector images_data_; + // stdout captured by fetch() on the worker thread and consumed by update() + std::string exec_output_; }; } // namespace image diff --git a/src/modules/image.cpp b/src/modules/image.cpp index d762f1eb..8c8132d7 100644 --- a/src/modules/image.cpp +++ b/src/modules/image.cpp @@ -45,6 +45,9 @@ auto waybar::modules::Image::getStrategy(const std::string& id, const Json::Valu void waybar::modules::Image::delayWorker() { thread_ = [this] { + // Do the blocking work (e.g. running a user script) here on the worker + // thread; update() then only parses the result and draws on the main thread. + strategy_->fetch(); dp.emit(); thread_.sleep_for(interval_); }; @@ -82,6 +85,15 @@ MultipleImageStrategy::MultipleImageStrategy(const std::string& id, const Json:: } } +void MultipleImageStrategy::fetch() { + // Run the (blocking) user script off the GTK main thread so the bar doesn't + // freeze for the script's duration on every interval. update() consumes the + // captured output. The static "entries" path takes priority and needs no exec. + if (config_["entries"].empty() && !config_["exec"].empty()) { + exec_output_ = util::command::exec(config_["exec"].asString(), "").out; + } +} + void MultipleImageStrategy::update() { // spdlog::info("update function run"); @@ -94,12 +106,12 @@ void MultipleImageStrategy::update() { if (!config_["entries"].empty()) { setImagesData(config_["entries"]); } else if (!config_["exec"].empty()) { - auto exec = util::command::exec(config_["exec"].asString(), ""); + // exec output was captured by fetch() on the worker thread Json::Value as_json; Json::Reader reader; - if (!reader.parse(exec.out, as_json)) { - spdlog::error("invalid json from exec {}", exec.out); + if (!reader.parse(exec_output_, as_json)) { + spdlog::error("invalid json from exec {}", exec_output_); return; } @@ -211,9 +223,8 @@ void MultipleImageStrategy::resetBoxAndMemory() { } void MultipleImageStrategy::handleClick(const Glib::ustring& data) { - auto msg = std::string(data); - - auto exec = util::command::exec(data, ""); + // Fire-and-forget: don't block the main loop waiting on the command's output. + util::command::forkExec(data); } SingleImageStrategy::SingleImageStrategy(const std::string& id, const Json::Value& config,