难以理解 Android 应用程序中的复杂多线程

我在理解应用程序中的多线程方面遇到了很大的问题，因此发现了一个错误。我已经检查过我认为所有的可能性，但仍然遇到各种（有时是意外的）错误。

也许这里有人可以建议我，我应该做什么。

在我的项目中，我使用两个外部库：

• 图形视图 https://github.com/jjoe64/GraphView- 提供图形绘制视图
• EventBus https://github.com/greenrobot/EventBus- 提供应用程序组件之间轻松通信的接口

至于应用程序，它的结构如下：

           MainActivity
            /        \
           /          \
        Thread        Fragment
   (ProcessThread)   (GraphFragment)

这个想法是ProcessThread计算数据并提供恒定的值流GraphFragment贯穿EventBus. In GraphFragment我有一个Series要求由GraphView.

根据数据实时更新图表example http://www.android-graphview.org/documentation/realtime-updates我需要制作一个新的Runnable所以我做了一个：

private class PlotsRun implements Runnable{

        @Override
        public void run() {
            mSeries1.appendData(new DataPoint(counter, getRandom()), true, 100);
            counter++;
            mHandler.post(this);
        }
}

当我从片段开始时onResume()方法一切都很顺利。

不幸的是，正如我所提到的，我正在使用来自另一个线程的外部数据。为了把它放进去GraphFragment我正在使用（根据文档 https://github.com/greenrobot/EventBus/blob/master/HOWTO.md) onEventMainThread() method.

在这里，无论我做什么，我都无法传递数据来更新我的图表PlotsRun目的。到目前为止我已经尝试过：

• using Queue- 增加价值onEventMainThread并进入PlotsRun。事实证明，可运行的读取速度比方法更新队列的速度快。
• 创建各种缓冲区 - 结果与Queue.
• calling mSeries1.appendData(new DataPoint(counter, getRandom()), true, 100);直接来自onEventMainThread- 在某些时候它会冻结。
• 创造onEvent()我的可运行对象中的方法并从那里调用mHandler.post()- 它阻塞了 UI 并且更新看起来像快照。
• 使用或不使用提到的所有内容synchronized() block.

对我来说很难理解的是这个可运行的程序（在某些时候）可以正常工作。

因为它是said http://android-developers.blogspot.com/2009/05/painless-threading.html在官方 Android 博客上，您无法从非 UI 线程更新 UI。这就是为什么我不能在里面使用另一个线程GraphFragment。但是当我检查我的可运行程序时，它正在主线程（UI）上运行。这就是为什么我无法创造无限while loop那里必须打电话mHandler.post(this).

而且它的行为仍然像另一个线程，因为它更快（调用更频繁）onEventMainThread method.

我该怎么做才能使用来自的数据更新我的图表（或我应该查看的位置）ProcessThread?

EDIT1:

回答@Matt Wolfe 的请求时，我包括了我认为针对此问题的代码中最重要的部分，其中所有必需的变量都显示了它们的声明方式。这是一个非常简单的例子：

MainActivity:

private ProcessThread testThread = new ProcessThread();

 @Override
    protected void onResume() {
        super.onResume();
        testThread.start();
    }


    private class ProcessThread extends Thread{
        private float value = 0f;
        private ReadingsUpdateData updater = new ReadingsUpdateData(values);
        public void run() {
            while(true) {
                value = getRandom();
                updater.setData(value);
                EventBus.getDefault().post(updater);
            }
        }
    }

GraphFragment:

private LineGraphSeries<DataPoint> mSeries1;
    long counter = 0;
    private Queue<ReadingsUpdateData> queue;

    @Override
    public void onResume() {
        super.onResume();
        mTimer2.run();
    }

    public void onEventMainThread(ReadingsUpdateData data){
        synchronized(queue){
            queue.add(data);
        }
    }

    private class PlotsRun implements Runnable{

        @Override
        public void run() {
            if (queue.size()>0) {
                mSeries1.appendData(new DataPoint(counter, queue.poll()), true, 100);
                counter++;
            }
            mHandler.post(this);
        }
    }

由于存在快速读取问题，因此添加了 runnable 中的 if 来进行保护。但它不应该在这里，因为应该总是有一些东西（至少我期望如此）。

还要补充一件事 - 当我简单地说Log.d并计算里面的变量onEventMainThread它正在更新并正确显示它的值，但不幸的是 logcat 不是主 UI。

EDIT2:

这主要是对@MattWolfe的回应comment https://stackoverflow.com/questions/30403513/difficulty-in-understanding-complex-multi-threading-in-android-app?noredirect=1#comment48897550_30403513

mHandler 只是在 GrapgFragment 中声明和创建的变量：

private final Handler mHandler = new Handler();
private Runnable mTimer2;

是的，没错，我正在使用mHandler.post()没有任何延迟。我会尝试使用一些延迟来查看是否有任何差异。

我之前没有提到的是ProcessThread还向其他片段提供数据 - 不用担心它们不会互相干扰或共享任何资源。这就是我使用的原因EventBus.

EDIT3:

这是我在另一个线程中用作另一个想法的代码GraphFragment and runOnMainThread method:

private MyThread thread = new MyThread();

    private class MyThread extends Thread {
        Queue<ReadingsUpdateData> inputList;
        ReadingsUpdateData msg;

        public MyThread() {
            inputList = new LinkedList<>();
        }

        public void run() {
            while(true) {
                try{
                    msg = inputList.poll();
                } catch(NoSuchElementException nse){
                    continue;
                }
                if (msg == null) {
                    continue;
                }
                getActivity().runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                        mSeries1.appendData(new DataPoint(counter, getRandom()), true, 100);
                        counter++;
                    }
                });
            }
        }

        public void onEvent(ReadingsUpdateData data){
            inputList.add(data);
        }
    }

不幸的是，它也不起作用。

首先，

下面的示例中的可运行部分只是为了动画实时数据更新，您可以选择调用appendData()无需创建新的可运行程序。你需要打电话appendData()不过从主线程。

第二，

您可以致电appendData()直接从您的功能onEventMainThread函数，但正如您所指出的，这种方法有时会挂起 UI，这种行为的一个可能原因是您可能正在发布事件太频繁，过于频繁地更新 UI 最终会在某个时候挂起 UI。您可以执行以下操作来避免这种情况：

过于频繁地更新 UI 也可能会挂起 UI， 这是一个解决方案：

放入一些逻辑ProcessThread保存最后发送的事件时间并在发送新事件之前进行比较，如果差异小于 1 秒，则保存它以供稍后发送，当下一次计算完成时，再次比较时间，如果现在大于 1 秒，而不是发送数组中的事件，或者可能只发送最新的事件，因为最新的计算可以代表图的最新状态，对吧？

希望有帮助！

Edit:（回应评论1和2）

我不确定您尝试过的内容可能是发布更新后的代码会给出更好的主意。但我认为您尝试在中实现时间检查功能onEventMainThread or in PlotsRun可以运行，对吗？如果是的话，恐怕对你没有太大帮助。相反，您需要做的是在 ProcessThread 内部实现此时间检查，并且仅在达到阈值时间时才发布新事件。出于以下原因：

1-后端的EventBus自动创建一个新的可运行对象并调用onEventMainThread在里面。所以，处理时间检查里面ProcessThread会在内存中生成更少不需要的可运行对象，从而减少内存消耗。

2-也不需要维护队列并生成新的可运行对象，只需更新中的数据onEventMainThread.

下面是一个最低限度的代码仅提供概念证明，您需要根据您的需求进行更新：

ProcessThread class:

private class ProcessThread extends Thread{
    private static final long TIME_THRESHOLD = 100; //100 MS but can change as desired
    private long lastSentTime = 0;
    private float value = 0f;
    private ReadingsUpdateData updater = new ReadingsUpdateData(values);
    public void run() {
        while(true) {
            if (System.currentTimeMillis() - lastSentTime < TIME_THRESHOLD) {
                try {
                    Thread.sleep(TIME_THRESHOLD - (System.currentTimeMillis() - lastSentTime));
                } catch (InterruptedException e) {}
            }

            value = getRandom();
            updater.setData(value);
            EventBus.getDefault().post(updater);
            lastSentTime = System.currentTimeMillis();
        }
    }
}

onEventMainThread method:

public void onEventMainThread(ReadingsUpdateData data){
    mSeries1.appendData(new DataPoint(counter, data), true, 100);
    counter++;
}