5

此时在 GUI 中生成一个关键事件,然后通过几个类传递给一个在单独线程中运行的类。线程正在等待一个关键事件,当收到一个来自更上层的变量时,类链被改变(见图)。但是在调试期间,变量没有改变。

线程正在访问的类当然是在它自己的线程中,因为它是从 GUI 调用的,这让我认为这是并发问题。

有没有办法使用原子整数或锁来解决这个问题?我已经看到了一些使用同步函数的示例,但是我无法让它们工作,因为它们没有解释类的要求。(我的意思是他们给你代码来做同步,但他们没有解释如何使一个类“同步”)。

类结构图 这是E类中线程的代码,因为您可以从上面的类中设置线程的对象引用,该类从上面的类接收A类的引用等。

    private Processor processor;

    public void run() {
        while (true) {
            if (keyevent != null) {


                keyevent = null;
                processor.I = 4;
            }
        }
    }

    public void SetProcessor(Processor processor) {
        this.processor = processor;
    }

调试注释的扩展。在调试过程中,如果我只调试 E 类中的线程并单步执行,代码功能正常,处理器。我收到值 4。但是,当我不调试该线程时,处理器中什么也没有发生,这就是为什么我认为这可能是一个并发问题。

使我在 B 类和原子整数中访问的变量,也使一些使用的函数同步。在调试环境之外仍然有功能:(

从 E 类调用的 B 类代码

    public void SetI(int value){//also tried using synchronized as well
        I.set(value);
    }

KeyEvent 是由 keyListener 在 GUI 类中生成的(只要按下一个键就会触发)。然后 KeyEvent 对象通过几个“涓滴”函数传递给 E 类,这些函数只是将它传递给下一个类,因此 GUI 调用 processor.setKeyevent(e),然后处理器调用 bus.setKeyevent(e) 等等依此类推,直到在 E 类中设置 KeyEvent 属性。

在系统初始化时,E 类中的线程启动,不断检查 Keyevent 属性的值,一旦 KeyEvent 不为空,即它已从 GUI(通过其他所有内容)传递一个,E 类然后设置值B 类中的整数属性。

正在发生的事情是,当按下一个键时,什么也没有发生,应该发生的是整数是 B 类,应该因为 E 类而改变,但事实并非如此。由于 net beans 不允许我一次调试两个线程,这让它有点尴尬,当我在 E 类的线程外部的代码中放置断点时,它不起作用,就好像线程没有运行或者如果它没有接收到 keyevent,如果我在线程中放置断点而不是在它之外工作,则 B 类中 I 的值会更改。如果它在调试之外运行它不起作用:/

4

2 回答 2

2

E 类不应该直接操作 B 类中的数据成员。那是各种各样的坏事。但这并不是你问题的真正重点。

为了让 B 中的 GUI 线程看到 E 中的线程所做的更改,您需要使用某种同步控制。通常我会建议使用一个AtomicInteger,但是你提到了一些摇摆的东西,所以我假设 B 类实际上是一个摇摆组件。在这种情况下,我发现在 EDT 上保留挥杆的东西并让 E 负责在 EDT 上呼叫 B 会更干净。

这就是我的意思。我已经消除了 C 类和 D 类,因为它们只是传递。我也忽略了线程的构造/设置和启动。我已经删除了 E 中的忙循环,并用CountDownLatch.

/**
 * Some GUI class, should only be accessed from the EDT
 */
public class B extends JPanel {

    private int value = 0;

    private E thatThreadObject;

    public void setE( E e ) {
        thatThreadObject = e;
    }    
    public void setValue( int newValue ) {
        value = newValue;
        System.out.println( "Got a new int value: " + value );
    }

    public void triggerKeyEvent() {
        thatThreadObject.keyEvent();
    }
}

/**
 * Must be thread-safe, as accessed from multiple threads
 */
public class E implements Runnable{
    private B thatGuiObject;
    // Note, latch is only good for one-time use.
    private final CountDownLatch latch = new CountDownLatch( 1 );

    public void setB( B b ) {
        thatGuiObject = b;
    }

    public void keyEvent() {
        // Wake up the waiting thread
        latch.countDown();            
    }

    @Override
    public void run() {
        try {
            // Wait for key event forever, better than busy looping
            latch.await();
            // Update B, but it's a Swing component so use EDT
            EventQueue.invokeLater( new Runnable() {
                @Override
                public void run() {
                    thatGuiObject.setValue( 4 );
                }
            } );
        }
        catch ( InterruptedException e ) {
            e.printStackTrace();
        }            
    }
}

看看Java并发教程

于 2013-05-08T21:26:56.150 回答
0

没有一些代码很难说,但你可能想看看 java.util.concurrent。在线程之间发送消息的一种安全方法是使用 BlockingQueues。

http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/BlockingQueue.html

该链接中的 Java API 页面提供了一个很好的代码示例。

于 2013-05-08T20:58:50.863 回答