如何实现可运行队列

Question

我正在尝试实现一个可运行队列，在异步任务期间依次执行（意味着队列中的下一个将在另一个完成后执行）。我编写了一个管理器来管理这些可运行对象和本身就是可运行对象的任务。然后，我获取异步任务中的第一个任务并运行它，希望它能够在队列中运行，但是它最终只是运行第一个可运行对象两次。任何人都可以帮助我处理我一直在使用的代码，或者向我指出一个可能有帮助的示例吗？

public class ConnectionManager {

    public static final int MAX_CONNECTIONS = 15;

    private ArrayList<Runnable> active = new ArrayList<Runnable>();
    private ArrayList<Runnable> queue = new ArrayList<Runnable>();

    private static ConnectionManager instance;

    public static ConnectionManager getInstance() {
        if (instance == null)
            instance = new ConnectionManager();
        return instance;
    }

    public void push(Runnable runnable) {
        queue.add(runnable);
        if (active.size() < MAX_CONNECTIONS)
            startNext();
    }

    private void startNext() {
        if (!queue.isEmpty()) {
            Runnable next = queue.get(0);
            queue.remove(0);
            active.add(next);

            Thread thread = new Thread(next);
            thread.start();
        }
    }

    public void didComplete(Runnable runnable) {
        active.remove(runnable);
        startNext();
    }
}

public class Task implements Runnable {
    Context con;
    String xmlFile;
    File taskFile;
    String Id;

    public void create(Context context, String xml, File task, String id) {
        this.con = context;
        this.xmlFile = xml;
        this.taskFile = task;
        this.Id = id;
        ConnectionManager.getInstance().push(this);
    }

    @Override
    public void run() {
        User.SendTask(con, xmlFile, taskFile, Id);

        ConnectionManager.getInstance().didComplete(this);
    }

Answer 1

使用 Executors.newSingleThreadExecutor() 怎么样？
http://developer.android.com/reference/java/util/concurrent/Executors.html#newSingleThreadExecutor%28java.util.concurrent.ThreadFactory%29

API描述解释了这个执行器执行只有一个任务按顺序执行并且具有无限的队列。我想这个可以满足你的要求。

Answer 2

我在我的一个应用程序中做了一些非常类似的事情，为了保持它的干净，我所做的就是让我的队列包含数据而不是要执行的线程。我使用一个 AsyncTask 来执行（它从系统分配的线程池中提取......可能会让您的管理更容易），并且在它的 doInBackground 方法中，我从队列中提取数据，对其进行操作，并在onPostExecute中再次调用我的入口方法。

Answer 3

不需要自己构建它，只需使用 ThreadPoolExecutor 即可为你做。构建一个 minPool 大小为 1、最大池大小为 15 的池，您应该已准备就绪。

Answer 4

为什么不使用 Queue 而不是 ArrayList？它更适合这里。

Answer 5

ArrayList 不是线程安全的，但您将它与线程一起使用。因此，不同的线程会互相妨碍。以下是可能发生的情况：

• 您使用各种可运行对象多次调用推送。所有这些方法都会同时调用 add 方法，但由于 add 不是线程安全的，因此第一个方法在第二个方法开始添加之前尚未完成添加，因此最终队列中只会有一个可运行对象。

• 然后 StartNext 会被同时调用很多次。其中一个线程运行“next =queue.Get()”，但是，在第一个线程有机会从队列中删除该项目之前，另一个线程也会调用“next=queue.Get()”，因此两个线程最终都会处理

您需要找到一个要使用的线程安全对象，或者添加某种类型的互斥/锁定机制以确保各个线程不会互相妨碍。