【问题标题】:Multi-Threading not working correctly多线程无法正常工作
【发布时间】:2013-07-12 03:53:14
【问题描述】:

编辑 这篇文章与我的学校作业有关,该作业要求我依靠摇摆来显示我的线程和用于阻塞的布尔标志。

我的应用程序创建了一堆“作业”对象,每个对象都包含一个线程。每个工作都属于一个生物。一个生物可以拥有多项工作,但在任何特定时刻只能执行其中一项。

我的线程使用 2 个布尔标志来判断它是否应该运行,称为“killFlag”和“goFlag”。它将它所属的生物指定为“目标”。每个目标都有一个布尔值“isWorking”来表示它是否正忙于其他工作。

这是每个作业应该运行的线程:

public void run() {
    long time = System.currentTimeMillis();
    long startTime = time;
    long stopTime = time + 1000 *  (long)( jobTime );
    double duration = stopTime - time;



    synchronized (this.target) {
        while (this.target.isWorking) {
            status = 'w';
            showStatus(); // hmmmmmmmm
            try {
                this.target.wait();
            } catch (InterruptedException e) {
            }
        }

        this.target.isWorking = true;
    }

    while (time < stopTime && !killFlag) {
        try {
            TimeUnit.MILLISECONDS.sleep(100);
        } catch (InterruptedException e) {
        }

        if (goFlag) {
            status = 'p';
            showStatus();
            time += 100;
            this.showProgress.setValue((int)(((time - startTime) / duration) * 100));
        } else {
            status = 'r';
            showStatus();
        }
    }//End While loop here

        showProgress.setValue(100);
        status = 'c';
        showStatus();
        synchronized (target) {
            target.isWorking = false;
            target.notifyAll();

    }
}

起初我以为是target.notifyAll(),因为它抛出了IllegalMonitorStateException,但是当我将其注释掉时,线程将构造对象,但是当我在 GUI 中查看它们时,80% 的对象显示为完整而没有我和其他 20% 的任何互动都表明该生物很忙。

起初我以为这是因为我过早地弹出了杀戮标志,但当我将其移低或移除时,症状仍然存在。我现在已经部署了,这里没有程序员哈哈,你能提供的任何建议都意味着全世界。

为了确保我提供了足够的信息,下面是我用于与线程交互的方法。以下方法适用于根据线程是否正在运行而更改的按钮。

public void showStatus() { //switch that changes status of button used to start / pause / display status of thread
    switch (this.status) {
        case 'r' :
            startJob.setEnabled(true);
            startJob.setText ("Run");
            break;
        case 'p' :
            startJob.setEnabled(true);
            startJob.setText("Pause");
            break;
        case 'w' :
            startJob.setEnabled(false);
            startJob.setText("Working");
            break;
        case 'c' :
            startJob.setEnabled(false);
            startJob.setText("Job Complete");
            break;
    }
}

private class theHandler implements ActionListener {//Listener for Button mentioned above
    public void actionPerformed (ActionEvent event) {
        if (event.getSource() == startJob) {
            if (goFlag) {
                goFlag = false;
            } else {
                goFlag = true;
                killFlag = false;
            }
        } else if (event.getSource() == stopJob) {
            if (killFlag) {
                //do nothing
            } else {
                killFlag = true;
                status = 'r';
            }
        }
    }
}

这让我很生气,我已经挖了 6 个小时来解决这个问题。

编辑

根据 MadProgrammer 的评论调整我的代码后,“target.notifyAll()”已修复。现在的问题似乎是所有线程在显示屏上显示为完整,即使按钮在状态之间随机闪烁几分之一秒。

编辑

下面包含许多针对 cme​​ts 的修改

下面是我如何定义工作类,其中定义了 killFlag、goFlag 等。

  class Job extends Item implements SearchableByName, Runnable {
int                                         index;
String                                      name;
int                                         creature;
double                                      jobTime;
Creature                                    target;
boolean                                     goFlag = false;
boolean                                     killFlag = false;
char                                        status;
JButton                                     startJob;
JButton                                     stopJob;
JProgressBar                                showProgress;
JPanel                                      p1;

下面是定义 Creature(目标)的地方,其中 boolean isWorking 驻留:

 class Creature extends Entity implements SearchableByName, SearchableByType, Runnable {
int                                     party;
int                                     empathy;
int                                     fear;
int                                     carryCapacity;
Float                                   age;
Float                                   height;
Float                                   weight;
boolean                                 isWorking = false;

作为对 cme​​ts 的回应,这里是我如何显示线程的图片:

【问题讨论】:

  • 新代码应该使用更高级别的并发抽象。您应该根据 Tasks 和 Executors 而不是线程来定义您的项目。正确使用 wait、notify 和 notifyAll 尤其困难。您讨论希望线程协调的方式的方式,您可能也应该使用 CountDownLatch。你自己开发的信号量标志至少应该被声明为 volatile,因为你不能保证你对它们所做的更新对其他线程是可见的。
  • 虽然有 GUI 的指示,但没有框架的标识。如果您使用的是 swing,我强烈建议您查看Concurrency in Swing,因为您违反了单线程规则;)
  • 如果这是家庭作业,请说这是家庭作业并在您的问题中说明作业的参数。我并不是要粗鲁或任何事情,我只是让您知道,如果您对此有所了解,您将在本网站上收到更好的反馈。另外,感谢您付出了诚实的努力,而不是说“这行不通,请帮我完成我的任务。”
  • 教师懒惰不想更新课程是一种耻辱。当你教计算机科学时,这不应该飞。
  • 我认为让学生用较低级别的原语完成一项作业是值得的,这样他们才能理解为什么他们应该在实际程序中使用较高级别的原语。

标签: java multithreading swing


【解决方案1】:

由于仍然缺少一些代码,我将首先列举一些假设;如果有任何不成立,我下面的答案可能是不正确的。

  1. 您提供的run() 方法位于Job 类中。
  2. 您指的“取消”按钮是stopJob JButton

如果您打算在第一次运行后重用相同的 Job 实例进行重启,那么您的基本问题是您的 run() 方法终止。您有一个检查!killFlagwhile 循环,但是一旦该循环结束(即一旦作业被取消和killFlag == true),就没有什么会导致它回到开始并等待后续@ 987654330@ 状态重新开始运行。 (另外,考虑actionPerformed() 方法中的stopJob 子句是否需要对goFlag 做一些事情。)

另一方面,如果您打算创建一个新的 Job 实例来表示重新启动的作业,那么您还没有显示任何可以执行此操作的代码。

我故意在上面的诊断中含糊不清,试图帮助您自己解决问题 - 这是最好的学习方式。 :) 如果您需要更多详细信息,我可以尝试提供它们,只需在评论中添加 LMK。

【讨论】:

  • 非常感谢!你真的对我需要做的事情有所了解!我修复了按钮周围的大部分问题。我想我要做的是在点击取消按钮并使用运行按钮启动线程时终止线程。我现在正在寻找安全的方法来做到这一点。再次感谢你,我感激不尽!
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2019-05-17
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2019-11-14
相关资源
最近更新 更多