Mercurial > hgrepos > Python2 > PyMuPDF

comparison mupdf-source/platform/java/example/Worker.java @ 3:2c135c81b16c

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
MERGE: upstream PyMuPDF 1.26.4 with MuPDF 1.26.7
author Franz Glasner <fzglas.hg@dom66.de>
date Mon, 15 Sep 2025 11:44:09 +0200
parents b50eed0cc0ef
children
comparison
equal deleted inserted replaced
0:6015a75abc2d 3:2c135c81b16c
1 // Copyright (C) 2004-2022 Artifex Software, Inc.
2 //
3 // This file is part of MuPDF.
4 //
5 // MuPDF is free software: you can redistribute it and/or modify it under the
6 // terms of the GNU Affero General Public License as published by the Free
7 // Software Foundation, either version 3 of the License, or (at your option)
8 // any later version.
9 //
10 // MuPDF is distributed in the hope that it will be useful, but WITHOUT ANY
11 // WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
12 // FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more
13 // details.
14 //
15 // You should have received a copy of the GNU Affero General Public License
16 // along with MuPDF. If not, see <https://www.gnu.org/licenses/agpl-3.0.en.html>
17 //
18 // Alternative licensing terms are available from the licensor.
19 // For commercial licensing, see <https://www.artifex.com/> or contact
20 // Artifex Software, Inc., 39 Mesa Street, Suite 108A, San Francisco,
21 // CA 94129, USA, for further information.
22
23 package example;
24
25 import java.awt.EventQueue;
26 import java.util.concurrent.LinkedBlockingQueue;
27
28 public class Worker implements Runnable
29 {
30 public static class Task implements Runnable {
31 public void work() {} /* The 'work' method will be executed on the background thread. */
32 public void run() {} /* The 'run' method will be executed on the UI thread if work() did not throw any exception. */
33 public void exception(final Throwable t) {} /* The 'exception' method will be executed on the UI thread if work() throws an exception. */
34 }
35
36 protected EventQueue eventQueue;
37 protected LinkedBlockingQueue<Task> queue;
38 protected boolean alive;
39 protected Thread thread;
40
41 public Worker(EventQueue eventQueue) {
42 this.eventQueue = eventQueue;
43 queue = new LinkedBlockingQueue<Task>();
44 thread = new Thread(this);
45 }
46
47 public void start() {
48 alive = true;
49 thread.start();
50 }
51
52 public void stop() {
53 alive = false;
54 thread.interrupt();
55 }
56
57 public void add(Task task) {
58 try {
59 queue.put(task);
60 } catch (InterruptedException x) {
61 return;
62 }
63 }
64
65 public void run() {
66 while (alive) {
67 final Task task;
68 try {
69 task = queue.take();
70 } catch (InterruptedException x) {
71 break;
72 }
73 try {
74 task.work();
75 eventQueue.invokeLater(task);
76 } catch (final Throwable t) {
77 eventQueue.invokeLater(new Runnable() {
78 public void run() {
79 task.exception(t);
80 }
81 });
82 }
83 }
84 }
85 }