如何在Java中以线程安全的方式使用mkdirs？

Question

在经历了 mkdirs() 的问题并浏览了互联网之后，我得到的印象是 mkdirs() 存在线程安全问题。

当多个线程可能尝试创建类似的文件结构时，有没有办法确保正确创建目录？

谢谢

（就我而言，我将在 Android 上使用它）

Answer 1

我不确定 Android 是否支持并发包，但我的看法是：

private static Lock fsLock = new ReentrantLock();

private void mkdir( File dir ) throws FileNotFoundException {

    if( dir.exists() ) {
        return;
    }

    fsLock.lock();
    try {
        if( !dir.exists() ) {
            log.info( "Creating directory {}", dir.getAbsolutePath() );
            if( !dir.mkdirs() ) {
                throw new FileNotFoundException( "Can't create directory " + dir.getAbsolutePath() );
            }
        }
    } finally {
        fsLock.unlock();
    }
}

如果目录已经存在，该方法会提前返回。如果它不存在，则只有一个线程会尝试创建它。

Answer 2

在序列化所有内容的工作线程中完成所有目录创建。您可以使用 Looper 和 Handler 来轻松地将调用 mkdirs 的 Runnables 发布到工作线程。创建完目录后，您可以在处理完最后发布的 Runnable 后调用 Looper.quit() 来结束线程。 Looper 的文档有示例代码表明这是多么微不足道的事情。

Answer 3

一种可能的解决方案是 MkDirService（如下所示），它只保证一个实例并在其自己的线程中运行。利用BlockingQueue。

首先是服务：

package mkdir;

import java.io.File;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class MkDirService extends Thread {

    private static MkDirService service;
    private BlockingQueue<File> pendingDirs = new LinkedBlockingQueue<File>();
    private boolean run = true;

    private MkDirService() {
    }

    public synchronized static MkDirService getService() {
        if (service == null) {
            service = new MkDirService();
            new Thread(service).start();
        }
        return service;
    }

    public void makeDir(File dir) {
        pendingDirs.add(dir);
    }

    public void shutdown() {
        run = false;
    }

    @Override
    public void run() {
        while (run || !pendingDirs.isEmpty()) {
            File curDir = null;
            try {
                curDir = pendingDirs.take();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            if (curDir != null && !curDir.exists()) {
                curDir.mkdir();
                System.out.println("Made: " + curDir.getAbsolutePath());
            }
        }
    }
}

测试：

package mkdir;

import java.io.File;

public class MkDirServiceTest {

    /**
     * @param args
     */
    public static void main(String[] args) {
        MkDirService mdServ = MkDirService.getService();
        mdServ.makeDir(new File("test1"));
        mdServ.makeDir(new File("test1/test2"));
        mdServ.makeDir(new File("test1/test3"));
        mdServ.shutdown();

    }
}

Answer 4

好吧，我知道这已经有一段时间不活跃了，但我想也许有一个简单的解决方案。您在该问题的评论中链接的文章似乎表明唯一的问题是目录未被创建。解决方案是这样做：

if (!f.mkdirs()) {
    f.mkdirs();
}

然而，这似乎效率低下，并且仍然可能存在问题。那么，为什么不简单地这样做：

while (!f.mkdirs()) {}

简单，但有效。

编辑：经过一番思考，该示例可能会滞后并可能导致线程锁定。因此，这可能是一个更好的主意：

while (!f.mkdirs()) { Thread.yield(); }

当然，只有当您处于可能导致线程锁定的线程中，并且只要不是高优先级情况时，才建议这样做。只是把这个放在那里。

Answer 5

即使这个线程有点旧，我想知道以下解决方案是否有问题：

package service;

import java.io.File;

public class FileService {

    public static synchronized boolean mkdirs( File dir ) {
        return dir.mkdirs();
    }
}