我已经使用 Java 几年了，但是我的线程知识是垃圾。我用谷歌搜索了很多，发现了一些关于一般使用的好信息，ProgressMonitorDialog但没有像我的确切情况一样。
我目前正在使用 aProgressMonitorDialog作为 的实例的包装器IRunnableWithProgress，而该实例又是 a 的包装器Thread。这工作正常，但现在我试图让取消按钮触发正在运行的线程上的中断，我可以处理它以优雅地终止操作。
需要注意的一件重要事情是我有两个插件；“数据”和“用户界面”。数据插件包含所有实际工作，并且必须独立于 UI 或任何 Eclipse 插件。UI 插件应该尽可能的薄。
这是我到目前为止所获得的代码的精炼版本。
数据：
public class Data {
public static Thread createThread() {
return new Thread() {
@Override
public void run() {
Thing t = new Thing();
t.operationA();
t.operationB();
t.operationC();
}
}
}
}
用户界面：
public class UI {
public void doOperation() {
try {
new ProgressMonitorDialog(getShell()).run(true, true, new MyOperation());
}
catch (Exception e) {
e.printStatckTrace();
}
}
public class MyOperation implements IRunnableWithProgress {
@Override
public void run(IProgressMonitor monitor) throws InterruptedException, InvocationTargetException {
monitor.beginTask("Task", 2);
try {
Thread myThread = Data.createThread();
myThread.start();
monitor.worked(1);
while (myThread.isAlive() && !monitor.isCanceled()) {}
if (monitor.isCanceled()) {
myThread.interrupt();
}
monitor.worked(1);
}
finally {
monitor.done();
}
}
}
}
因此，当单击取消按钮时，myThread.interrupt()将调用。现在线程需要响应中断。Data.createThread()现在看起来像这样：
public static Thread createThread() {
return new Thread() {
@Override
public void run() {
Thing t = new Thing();
t.operationA();
if (Thread.currentThread.isInterrupted()) {
// Tidy up
return;
}
t.operationB();
if (Thread.currentThread.isInterrupted()) {
// Tidy up
return;
}
t.operationC();
if (Thread.currentThread.isInterrupted()) {
// Tidy up
return;
}
}
}
}
像这样轮询中断状态可能相当冗长，但我看不出这会导致任何问题。
但是，如果Thing.operationA()不是原子的，并且可以在该函数中被中断怎么办：
public class Thing {
public void operationA() {
atomic1();
// How would I detect and handle a change to the interrupted state here?
atomic2();
}
public void operationB() {
// One atomic operation
}
public void operationC() {
// One atomic operation
}
}
我将如何检测和处理 和 之间的中断状态的atomic1()变化atomic2()？是不是像Thread.currentThread.isInterrupted()再次轮询一样简单？或者我需要传递一些volatile对象来跟踪中断状态吗？我应该扔吗InterruptedException什么地方吗？
我的第二个问题是关于跟踪和报告进度的。我明白IProgressMonitor.worked()应该如何使用。如前所述，我的数据线程包含 3 个操作。是否可以将该信息传递给 UI，以便我可以跟踪进度ProgressMonitorDialog？
理想情况下，是这样的：
public static Thread createThread() {
return new Thread() {
@Override
public void run(IProgressMonitor monitor) {
Thing t = new Thing();
t.operationA();
monitor.worked(1);
if (Thread.currentThread.isInterrupted()) {
// Tidy up
return;
}
t.operationB();
monitor.worked(1);
if (Thread.currentThread.isInterrupted()) {
// Tidy up
return;
}
t.operationC();
monitor.worked(1);
if (Thread.currentThread.isInterrupted()) {
// Tidy up
return;
}
}
}
}
但是如前所述，数据不能依赖于 Eclipse，因此IProgressMonitor在这种情况下传递不起作用。
我可以在我的线程中有一个变量跟踪进度，然后调用类似myThread.getProgress()从 UI 线程异步调用类似的东西来用新工作更新进度条吗？我不确定这是多么可行（当我写这个问题时它突然出现在我的脑海中）所以我接下来会尝试。
这里有很多信息和问号，如果我的风格有点分散，请见谅。如果需要，我可以详细说明，但这已经是一堵文字墙了。任何信息，建议或想法表示赞赏。