1

我正在使用 GJS 和 GNOME 平台用 JavaScript 编写一个简单的桌面应用程序:GTK+、GLib、Gio、GObject。下面的代码说明了我面临的情况,并且更容易复制,因为它不需要访问应用程序使用的文件。简而言之,我想在完成一系列异步任务(加载一系列文件的内容)后运行指示的代码行。我如何在 GJS 中做到这一点,最好使用 Gio 或 JavaScript 本身的东西?

#!/usr/bin/gjs

const Lang = imports.lang;
const Gio = imports.gi.Gio;
const GLib = imports.gi.GLib;
const GObject = imports.gi.GObject;
const Gtk = imports.gi.Gtk;

const Home = new Lang.Class({
  Name: "Home",

  // Start snippet 1            
  _enumerateChildrenAsyncCallback: function(dir, result) {
    let fileEnumerator = dir.enumerate_children_finish(result);
    let displayName, file, fileInfo, fileType, iter;
    while ((fileInfo = fileEnumerator.next_file(null))) {
      iter = this.model.append();
      displayName = fileInfo.get_display_name();
      this.model.set(iter, [0], [displayName], 1);

      file = dir.get_child(fileInfo.get_name());
      fileType = file.query_file_type(Gio.FileQueryInfoFlags.NONE, null);
      if (fileType != Gio.FileType.REGULAR) continue;

      file.load_contents_async(null, function(file, result) {
        let [success, contents, etag] = file.load_contents_finish(result);
        let message = "";
        if (success) {
          message = "Finished loading file %s";
        } else {
          message = "Couldn't load file %s";
        }
        log(message.replace("%s", file.get_basename()));
      });
    }
  },

  _init: function() {
    this.application = new Gtk.Application();
    this.application.connect("activate", Lang.bind(this, this._onActivate));
    this.application.connect("startup", Lang.bind(this, this._onStartup));
  },

  _onActivate: function() {
    this._window.show_all();
  },

  _onStartup: function() {
    this.model = new Gtk.ListStore();
    this.model.set_column_types([GObject.TYPE_STRING]);
    let renderer = new Gtk.CellRendererText();

    let dir = Gio.file_new_for_path(GLib.get_home_dir());
    dir.enumerate_children_async("standard::*",
      Gio.FileQueryInfoFlags.NONE,
      GLib.PRIORITY_DEFAULT,
      null,
      Lang.bind(this, this._enumerateChildrenAsyncCallback),
      null);
    /*
     * I would like this line to be run after all files have been read.
     *
     */
    this.model.set_sort_column_id(0, Gtk.SortType.ASCENDING);

    let column = new Gtk.TreeViewColumn({
      title: "Files"
    });
    column.pack_start(renderer, true);
    column.add_attribute(renderer, "text", 0);
    let view = new Gtk.TreeView({
      model: this.model
    });
    view.append_column(column);
    let scrolled = new Gtk.ScrolledWindow();
    scrolled.hscrollbar_policy = Gtk.PolicyType.AUTOMATIC;
    scrolled.Vscrollbar_policy = Gtk.PolicyType.AUTOMATIC;
    scrolled.add(view);
    this._window = new Gtk.ApplicationWindow({
      application: this.application,
      default_height: 300,
      default_width: 400,
      title: "Home, sweet home"
    });
    this._window.add(scrolled);
  }
});

let home = new Home();
home.application.run(ARGV);

PS:在提供的代码中,在完成所有异步任务之前运行指定的代码行不会阻止应用程序正常运行。但是,我想在应用程序启动时对列表进行一次排序,而不是在每次读取文件时对列表进行排序。而且,当然,知道如何做到这一点在其他情况下也很有帮助。

4

1 回答 1

1

如果我正确理解您要执行的操作,则需要类似Promise.all(). 不幸的是,GJS 还没有 Promise 库。

我建议在你的枚举子回调中做这样的事情(我已经编辑了一些与我试图说明的内容无关的部分):

_enumerateChildrenAsyncCallback: function(dir, result) {
  let fileEnumerator = dir.enumerate_children_finish(result);
  let displayName, file, fileInfo, fileType, iter;

  let pendingOperations = new Set();

  while ((fileInfo = fileEnumerator.next_file(null))) {
    file = dir.get_child(fileInfo.get_name());
    fileType = file.query_file_type(Gio.FileQueryInfoFlags.NONE, null);
    if (fileType != Gio.FileType.REGULAR) continue;

    pendingOperations.add(file);

    file.load_contents_async(null, (file, result) => {
      let [success, contents, etag] = file.load_contents_finish(result);

      pendingOperations.delete(file);
      if (pendingOperations.size === 0)
        this.model.set_sort_column_id(0, Gtk.SortType.ASCENDING);
    });
  }
},

乍一看,这似乎在pendingOperations清除其第一个元素和添加第二个元素之间存在竞争条件,但load_contents_async回调不会开始被调用,直到主循环的下一次迭代,所以你应该在那里安全。

于 2015-08-23T18:21:43.980 回答