1

如果您查看代码，我有两个被调用、按下和释放的 ArrayList，它们是全局的。我要做的是用要按下的键更新这些数组，然后将这些更新的数组传递给我的线程，或者更新线程..这是我对我必须做的事情有点迷茫的部分.

当前的示例（如果运行则未经测试）是我在实际程序中所拥有的基本示例。当我运行它时，它会按一次按钮，然后它会抛出错误，我不记得错误，因为我现在无法测试它，但这与我使用线程的方式有关。

问题 一旦线程启动，我如何将数组传递给我的线程。

代码示例：

import oscP5.OscEventListener;
import oscP5.OscMessage;
import oscP5.OscP5;
import oscP5.OscStatus;

import java.awt.*;
import java.awt.event.KeyEvent;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

public class Main implements OscEventListener {

protected BlockingQueue<Integer> _KeyQue = new ArrayBlockingQueue<>(1024);

Producer producer = new Producer(this._KeyQue);
Consumer consumer = new Consumer(this._KeyQue);
ThreadTest threadTest = new ThreadTest(this._KeyQue);

Thread prod;
Thread con;
Thread threadT;

OscP5 osc = new OscP5(this, 22556);

public static void main(String[] argv) {
    Main main = new Main();
    main.setup();
}

public void setup() {
    prod = new Thread(producer);
    con = new Thread(consumer);
    threadT = new Thread(threadTest);

    prod.start();
    con.start();
    threadT.start();

}

@Override
public void oscEvent(OscMessage theMessage) {
    float val = Float.parseFloat(theMessage.arguments()[0].toString());

    if (val == 1.0) {
        producer.addKey(KeyEvent.VK_W);
        producer.addKey(KeyEvent.VK_S);
    } else {
        consumer.removeKey(KeyEvent.VK_S);
    }
   threadTest.run();
}

@Override
public void oscStatus(OscStatus theStatus) {}

public class Producer implements Runnable {
    protected BlockingQueue<Integer> _KeyQue = null;

    public void addKey(int key) {
        try {
            this._KeyQue.put(key);
            System.out.println("Key " + key +" added to queue");
        } catch (InterruptedException e) {
            System.out.println(e.getMessage());
        }
    }

    public Producer(BlockingQueue<Integer> _KeyQue) {
        this._KeyQue = _KeyQue;
    }

    public void run() {

    }
}

public class Consumer implements Runnable {
    protected BlockingQueue<Integer> _KeyQue = null;

    public void removeKey(int key) {
        try {
            this._KeyQue.remove(key);
            System.out.println("key " + key + " removed from queue");
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }

    public Consumer(BlockingQueue<Integer> _KeyQue) {
        this._KeyQue = _KeyQue;
    }

    public void run() {

    }
}

public class ThreadTest implements Runnable {

    protected BlockingQueue<Integer> _KeyQue = null;

    public ThreadTest(BlockingQueue<Integer> _KeyQue) {
        this._KeyQue = _KeyQue;
    }

    public void run() {
        try {
            Robot robot = new Robot();

            while(!this._KeyQue.isEmpty()) {
                for (Integer x : this._KeyQue) {
                    System.out.println("Keys in que: " + x);
                    Thread.sleep(500);
                }
            }

        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }
}
}

编辑： 好的，所以我查看了线程和 BlockingQueue，但我仍然不知道如何在不锁定程序的情况下继续运行ThreadTest 的 run()方法。在此示例中，它根本不运行。当我直接调用threadTest.run()时，它会将程序锁定在其中，并且不允许添加或删除元素。

所以我需要做的是能够在后台运行一个不断运行的线程，通过*_KeysQueue()*循环，并且在这个例子中，打印出与键关联的数字。这一切都应该发生，同时允许我添加和删除密钥。

4

3 回答 3

0

在你的类中有一个 setter 方法

public class ThreadTest implements Runnable {
    ....
    public void setPressedList(ArrayList<Integer> e) {
       this.pressed = e;
    }
    public void setReleasedList(ArrayList<Integer> f)
    {
       this.released = f
    }
}
于 2013-01-12T18:06:09.550 回答
0

ArrayList不是线程安全的，因此您不应该以这种方式使用它们：它可以工作，也可以失败。

此外，您应该使用某种同步机制，而不是无谓地消耗资源的忙等待。

所以看看BlockingQueue集合，它会给你一个简单的线程之间的数据传递机制。

于 2013-01-12T18:18:12.883 回答
0

您可以有一个BlockingQueue和一个方法来添加将从其他线程调用的元素。您可以拥有一个静态方法addKey，该方法可以从其他所有线程访问，并且会寻找将新密钥添加到BlockingQueue.

您可以在那里使用生产者-消费者模式，您可以在博客The Java Specialists中查看Java Concurrency In Practice一书或将我带到这本书的链接。这本书有所有队列、并发或同步列表的示例，实现代码做几件事的方法，所有这些都不需要停下来阅读 50 页的内容。每个问题的一个例子和几段。

于 2013-01-12T18:27:27.530 回答