Android中的读写器任务队列

Question

我正在使用 reading tasks 和 writing tasks 制作一个 android 应用程序。 我想得到以下行为：

• 任务在队列中执行
• 读取任务可以同时运行。
• 写作任务非常重要，不能同时运行，如果正在运行一个写作任务就不能运行任何其他任何类型的任务

我正在搜索解决此问题的库。 我可以用信号量解决这个问题，但我害怕在 android 中解决这些问题。 在我对 android 的有限经验中，我知道管理这些东西的生命周期非常困难。并且正确执行编写任务非常重要。

对不起我的英语。谢谢

Answer 1

为您的任务使用fixed thread pool executor，让您的所有任务使用相同的ReadWriteLock，然后让它自行解决。一般示例：

public class ReadTask implements Runnable {        
    private final ReadWriteLock lock;
    public ReadTask (ReadWriteLock lock) {
        this.lock = lock;
    }
    @Override public void run () {
        lock.readLock().lock();
        // do stuff
        lock.readLock().unlock();
    }
}

public class WriteTask implements Runnable {
    private final ReadWriteLock lock;
    public WriteTask (ReadWriteLock lock) {
        this.lock = lock;
    }
    @Override public void run () {
        lock.writeLock().lock();
        // do stuff
        lock.writeLock().unlock();
    }
}

然后，设置您的初始执行程序并锁定：

ExecutorService executor = Executors.newFixedThreadPool(NUMBER_OF_THREADS);
ReadWriteLock lock = new ReentrantReadWriteLock();

当你想要排队任务时：

// a write task:    
executor.execute(new WriteTask(lock));

// a read task:
executor.execute(new ReadTask(lock));

只要确保你总是打开锁；如有必要，您可以使用 try ... finally 块，但实际上，因为 run() 不应该抛出任何异常，所以如果您按照应有的方式正确处理 run() 中的所有内容，则不会遇到问题。