Android 中SQLite进行读写时，涉及的并发处理问题

相信做Android开发牵扯到SQLite数据库的时候，我们都知道数据库的CRUD都是不支持多线程操作的。当我们要使用多线程的时候，基本上就是为每个线程分配一个SQLiteOpenHelper对象来进行操作，但这样就会产生很大的性能问题，消耗更多的内存空间。

在这种情况下，我们一般就会只使用一个SQLiteOpenHelper对象来操作，如果我们要使用多线程，这时就需要注意SQLiteDataBase.close()调用的时机，因为你是使用的同一个引用，比如在一个线程中当一个Add操作结束后立刻关闭了数据库连接，而另一个现场中正准备执行查询操作，但此时db已经被关闭了，然后就会报下面的异常错误。

java.lang.IllegalStateException: Cannot perform this operation because the connection pool has been closed.
java.lang.IllegalStateException: attempt to re-open an already-closed object: SQLiteDatabase:
java.lang.IllegalStateException: attempt to re-open an already-closed object: SQLiteDatabase:

在这种情况下，我们一般会给CRUD添加一个 synchronized关键字，然后自己进行引用计数AtomicInteger。

关于AtomicInteger，它是一个提供原子操作的Integer的类，AtomicInteger是线程安全的，我们看一下它提供的接口

//获取当前的值
public final int get()
//取当前的值，并设置新的值
public final int getAndSet(int newValue)
//获取当前的值，并自增
public final int getAndIncrement()
//获取当前的值，并自减
public final int getAndDecrement()
//获取当前的值，并加上预期的值
public final int getAndAdd(int delta)

public class AtomicIntegerDemo {
public static void main(String[] args) {
AtomicInteger ai=new AtomicInteger(0);
int i1=ai.get();
v(i1);
int i2=ai.getAndIncrement();
v(i2);
}
static void v(int i) {
System.out.println("i : "+i);
}
}

以上我们可以看到AtomicInteger的基本的使用，那么结合SQLiteOpenHelper的使用如下，

public class DatabaseManager {

private AtomicInteger mOpenCounter = new AtomicInteger();
private static DatabaseManager instance;
private static SQLiteOpenHelper mDatabaseHelper;
private SQLiteDatabase mDatabase;

public static synchronized void initializeInstance(SQLiteOpenHelper helper) {
if (instance == null) {
instance = new DatabaseManager();
mDatabaseHelper = helper;
}
}

public static synchronized DatabaseManager getInstance(SQLiteOpenHelper helper) {
if (instance == null) {
initializeInstance(helper);
}
return instance;
}

public synchronized SQLiteDatabase getWritableDatabase() {
if(mOpenCounter.incrementAndGet() == 1) {
// Opening new database
mDatabase = mDatabaseHelper.getWritableDatabase();
}
return mDatabase;
}

public synchronized SQLiteDatabase getReadableDatabase() {
if(mOpenCounter.incrementAndGet() == 1) {
// Opening new database
mDatabase = mDatabaseHelper.getReadableDatabase();
}
return mDatabase;
}

public synchronized void closeDatabase() {

if(mOpenCounter.decrementAndGet() == 0) {
// Closing database
mDatabase.close();
}
}

通过这种方式，我们就基本解决了多线程并发操作Sqlite时产生的问题。

本文参考了（http://www.cnblogs.com/wangmars/p/4530670.html），感谢