3.5.8.1. 后台任务使用示例

使用 BackgroundWorkProgressWindow 展示和控制后台任务

启动后台任务时，我们一般会要显示一个简单的 UI 界面：

1. 展示给用户，请求的任务还在执行中，

2. 允许用户退出长时间执行的任务，

3. 如果能获取任务执行进度的话，展示目前的进度。

平台通过 BackgroundWorkWindow 和 BackgroundWorkProgressWindow 工具类满足了这些需求。 这些类带有静态方法，可以用来将后台任务和一个模态窗相关联，这个模态窗带有标题、描述、进度条以及一个可选的 Cancel 按钮。 这两个类的区别在于，BackgroundWorkProgressWindow 使用了一个确定的进度条，应当在能估算任务进度的情况下使用。相反，BackgroundWorkWindow 应当在无法估算任务时长的情况使用。

下面我们用一个开发任务作为示例：

• 一个给定的界面包含展示学生列表的表格，可以多选。

• 当用户按下某个按钮时，系统会给这些选中的学生发送邮件，而且此时 UI 不会被 block 住，并能取消发送邮件的操作。

示例实现：

import com.haulmont.cuba.gui.backgroundwork.BackgroundWorkProgressWindow;
public class StudentBrowse extends StandardLookup<Student> {
    @Inject
    private Table<Student> studentsTable;
    @Inject
    private EmailService emailService;
    @Subscribe("studentsTable.sendEmail")
    public void onStudentsTableSendEmail(Action.ActionPerformedEvent event) {
        Set<Student> selected = studentsTable.getSelected();
        if (selected.isEmpty()) {
            return;
        }
        BackgroundTask<Integer, Void> task = new EmailTask(selected);
        BackgroundWorkProgressWindow.show(task, (1)
                "Sending reminder emails", "Please wait while emails are being sent",
                selected.size(), true, true (2)
        );
    }
    private class EmailTask extends BackgroundTask<Integer, Void> { (3)
        private Set<Student> students; (4)
        public EmailTask(Set<Student> students) {
            super(10, TimeUnit.MINUTES, StudentBrowse.this); (5)
            this.students = students;
        }
        @Override
        public Void run(TaskLifeCycle<Integer> taskLifeCycle) throws Exception {
            int i = 0;
            for (Student student : students) {
                if (taskLifeCycle.isCancelled()) { (6)
                    break;
                }
                emailService.sendEmail(student.getEmail(), "Reminder", "Don't forget, the exam is tomorrow",
                        EmailInfo.TEXT_CONTENT_TYPE);
                i++;
                taskLifeCycle.publish(i); (7)
            }
            return null;
        }
    }
}

周期性的在后台使用定时器和 BackgroundTaskWrapper 刷新界面数据

BackgroundTaskWrapper 是一个 BackgroundWorker 的很小的工具包装类。 提供了简单的 API 用来重复的启动、重启和取消同类型的后台任务。

下面这个开发任务示例展示了使用方法：

• 一个排名监控界面需要展示并自动更新数据。

• 数据加载很慢，所以需要在后台加载。

• 在界面展示最新的数据更新时间。

• 数据通过简单的过滤器（复选框）进行过滤。

• 由于某些原因，如果数据刷新失败了，界面应当告诉用户：

示例实现：

@UiController("playground_RankMonitor")
@UiDescriptor("rank-monitor.xml")
public class RankMonitor extends Screen {
    @Inject
    private Notifications notifications;
    @Inject
    private Label<String> refreshTimeLabel;
    @Inject
    private CollectionContainer<Rank> ranksDc;
    @Inject
    private RankService rankService;
    @Inject
    private CheckBox onlyActiveBox;
    @Inject
    private Logger log;
    @Inject
    private TimeSource timeSource;
    @Inject
    private Timer refreshTimer;
    private BackgroundTaskWrapper<Void, List<Rank>> refreshTaskWrapper = new BackgroundTaskWrapper<>(); (1)
    @Subscribe
    public void onBeforeShow(BeforeShowEvent event) {
        refreshTimer.setDelay(5000);
        refreshTimer.setRepeating(true);
        refreshTimer.start();
    }
    @Subscribe("onlyActiveBox")
    public void onOnlyActiveBoxValueChange(HasValue.ValueChangeEvent<Boolean> event) {
        refreshTaskWrapper.restart(new RefreshScreenTask()); (2)
    }
    @Subscribe("refreshTimer")
    public void onRefreshTimerTimerAction(Timer.TimerActionEvent event) {
        refreshTaskWrapper.restart(new RefreshScreenTask()); (3)
    }
    public class RefreshScreenTask extends BackgroundTask<Void, List<Rank>> { (4)
        private boolean onlyActive; (5)
        protected RefreshScreenTask() {
            super(30, TimeUnit.SECONDS, RankMonitor.this);
            onlyActive = onlyActiveBox.getValue();
        }
        @Override
        public List<Rank> run(TaskLifeCycle<Void> taskLifeCycle) throws Exception {
            List<Rank> data = rankService.loadActiveRanks(onlyActive); (6)
            return data;
        }
        @Override
        public void done(List<Rank> result) { (7)
            List<Rank> mutableItems = ranksDc.getMutableItems();
            mutableItems.clear();
            mutableItems.addAll(result);
            String hhmmss = new SimpleDateFormat("HH:mm:ss").format(timeSource.currentTimestamp());
            refreshTimeLabel.setValue("Last time refreshed: " + hhmmss);
        }
        @Override
        public boolean handleTimeoutException() { (8)
            displayRefreshProblem();
            return true;
        }
        @Override
        public boolean handleException(Exception ex) { (9)
            log.debug("Auto-refresh error", ex);
            displayRefreshProblem();
            return true;
        }
        private void displayRefreshProblem() {
            if (!refreshTimeLabel.getValue().endsWith("(outdated)")) {
                refreshTimeLabel.setValue(refreshTimeLabel.getValue() + " (outdated)");
            }
            notifications.create(Notifications.NotificationType.TRAY)
                    .withCaption("Problem refreshing data")
                    .withHideDelayMs(10_000)
                    .show();
        }
    }
}