多线程锁的问题

public class Test extends Thread {
  private static final ReentrantReadWriteLock rrwl = new ReentrantReadWriteLock();
  private final Lock rl = rrwl.readLock();
  private final Lock wl = rrwl.writeLock();

  public static void main(String[] args) {
     new Test().start();
     new Test().start();
     new Test().start();
     new Test().start();
     new Test().start();
     new Test().start();
  }
  public void A() {
    rl.lock();
    ...
    rl.unlock();
  }

  public void B() {
    wl.lock();
     ...
    wl.unlock();
  }

/**
 * 这里的实现对吗？
 */
  public void C() {
    wl.lock();
     ...
    wl.unlock();
  }

}

/**
 * 该程序测试成功，数据库中没有重复数据，队列中也没有丢数据
 */
public class Processor extends Thread {
	private TestDao testDao;
	private ReceivedQueue receivedQueue;
	private static final ReentrantReadWriteLock rwLockCache = new ReentrantReadWriteLock();
	private static final ReentrantReadWriteLock rwLockDb = new ReentrantReadWriteLock();
	private static Map<String, UserVO> insertMap = new HashMap<String, UserVO>();
        private static Map<String, UserVO> updateMap = new HashMap<String, UserVO>();

	public Processor(ReceivedQueue receivedQueue, int dbTarget) {
		this.receivedQueue = receivedQueue;
		DaoManager daoManager = DaoConfig.getDaoManager(dbTarget);
		testDao = (TestDao)daoManager.getDao(TestDao.class);
	}

	public void run() {
		while(true) {
			UserVO testvo = receivedQueue.dequeue();
			if(testvo != null) {
				addToList(testvo);

				if(insertMap.size() > 5000) {
					insToDb();
				}
				if(updateMap.size() > 5000) {
					updeToDb();
				}
			} else {
				if(insertMap.size() > 0) {
					insToDb();
				}
				if(updateMap.size() > 0) {
					updeToDb();
				}
				if(receivedQueue.isStop() && receivedQueue.isEmpty()) {
					break;
				}
			}
		}
	}

	public void addToList(UserVO uservo) {
		rwLockDb.readLock().lock();
		try	{
			UserVO user = testDao.getUser(uservo.getMsisdn());
			if(user == null) {
				addToInsList(uservo);
			} else {
				addToUpdeList(uservo);
			}
		} finally {
			rwLockDb.readLock().unlock();
		}
	}
	public void insToDb() {
		rwLockDb.writeLock().lock();
		try	{
		  testDao.batchInsert((List<UserVO>)insertMap.values());			
		} finally {
		  insertMap.clear();
		  rwLockDb.writeLock().unlock();
		}
	}
	public void updeToDb() {
		rwLockDb.writeLock().lock();
		try	{
		  testDao.batchUpdate((List<UserVO>)updateMap.values());			
		} finally {
		  updateMap.clear();
		  rwLockDb.writeLock().unlock();
		}
	}
	public void addToInsList(UserVO user) {
		wrLockCache.writeLock().lock();
		try	{
			UserVO uv = insertMap.get(user.getMsisdn());
			if(uv!=null) {
				if(user.getUpdateDate().after(uv.getUpdateDate())) {
					uv.put(user.getMsisdn(), user);
				}
			} else {
				uv.put(user.getMsisdn(), user);
			}
		} finally {
			wrLockCache.writeLock().unlock();
		}
	}

	public void addToUpdeList(UserVO user) {
		wrLockCache.writeLock().lock();
		try	{
			UserVO uv = updateMap.get(user.getMsisdn());
			if(uv!=null) {
				if(user.getUpdateDate().after(uv.getUpdateDate())) {
					uv.put(user.getMsisdn(), user);
				}
			} else {
				uv.put(user.getMsisdn(), user);
			}
		} finally {
			wrLockCache.writeLock().unlock();
		}
	}
}

 /*
 * 这是启动程序，另外有一个job定时去解决文件，将解析出的数据不断地调用receivedQueue.enqueue(UserVO uservo)压入接受队列
 */
public class StartMainApp {
	private static ThreadPoolManager tpm = new ThreadPoolManager();

	public static void main(String[] args) {
		ReceivedQueue receivedQueue = new UserReceivedQueue();
		for(int i =0;i < 4;i++) {
			tpm.execute(new Processor(receivedQueue, 0));
		}
	}
}

rwLockDb.writeLock().lock();
//将insertMap拷贝出来。
List list = insertMap.values();
insertMap.clear();//然后清除原LIST，对共享资源操作。
rwLockDb.writeLock().unlock();

//数据库操作放到读写锁外面，不是对共享资源操作不要放这里
 testDao.batchInsert((list);			

public void insToDb() {
   rwLockDb.writeLock().lock();
   try {
       testDao.batchInert(new ArrayList(insertMap.values()));
   } finally {
      insertMap.clear();
      rwLockDb.writeLock().unlock();
   }
}