进程间的同步

在看Replugin源码时，发现在对插件apk文件解析之前，对这个文件加了一个ProcessLocker锁。看名字是进程锁，但我以前还没有听说过进程锁这个概念，因此本文就来看一下这个ProcessLocker是什么东西。

先来看一下ProcessLocker的使用:

    ProcessLocker lock = new ProcessLocker(context, lockFileName);

    if (!lock.tryLockTimeWait(5000, 10)) { //获取文件锁 
        ...获取锁失败
    }

    ...做一些需要防止进程并发的操作

    lock.unlock();

那么它内部是如何实现的呢? 它的实现核心是使用 Java FileLock

构造方法:

public ProcessLocker(Context context, String filename) {
    mContext = context;
    try {
        mFile = new File(filename); //创建一个锁文件
        mFileOutputStream = mContext.openFileOutput(filename, 0); 
        if (mFileOutputStream != null) {
            mFileChannel = mFileOutputStream.getChannel();
        }
        if (mFileChannel == null) {  //获取 FileChannel失败则不能执行加锁操作
            if (LOGR) {
                LogRelease.e(MAIN_TAG, "channel is null");
            }
        }
    } catch (Throwable e) {
        if (LOGR) {
            LogRelease.e(MAIN_TAG, e.getMessage(), e);
        }
    }
}

加锁方法 tryLockTimeWait

这个方法允许进程在 (ms / interval)的时间内重复获取文件锁

public final synchronized boolean tryLockTimeWait(int ms, int interval) {
        if (mFileChannel == null) {
            return false;
        }
        // 自动修正到最小值，避免死锁
        if (ms <= 0) {
            ms = 1;
        }
        if (interval <= 0) {
            interval = 1;
        }
        try {
            for (int i = 0; i < ms; i += interval) { //
                try {
                    mFileLock = mFileChannel.tryLock();
                } catch (IOException e) {
                    // 获取锁失败会抛异常，此处忽略
                }
                if (mFileLock != null) {
                    return true;
                }
                Thread.sleep(interval, 0);//休息一下等下继续获取锁
            }
        } catch (Throwable e) {
            if (LOGR) {
                LogRelease.e(MAIN_TAG, e.getMessage(), e);
            }
        }
        return false;
    }

关锁方法unlock

/**
* 释放并且删除该锁文件
*/
public final synchronized void unlock() {
    if (mFileLock != null) {
        try {
            mFileLock.release();
        } catch (Throwable e) {
        }
    }

    if (mFileChannel != null) {
        try {
            mFileChannel.close();
        } catch (Throwable e) {
        }
    }

    if (mFileOutputStream != null) {
        try {
            mFileOutputStream.close();
        } catch (Throwable e) {
        }
    }

    // 删除锁文件
    if (mFile != null && mFile.exists()) {
        mFile.delete();
    }
}