[ROCKETMQ-261] Use write lock when destroy IndexService

SatanDaddy · Aug 11, 2017 · 332df78 · 332df78
1 parent f613c3b
commit 332df78
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/store/src/main/java/org/apache/rocketmq/store/index/IndexService.java b/store/src/main/java/org/apache/rocketmq/store/index/IndexService.java
@@ -142,15 +142,15 @@ private void deleteExpiredFile(List<IndexFile> files) {
 
     public void destroy() {
         try {
-            this.readWriteLock.readLock().lock();
+            this.readWriteLock.writeLock().lock();
             for (IndexFile f : this.indexFileList) {
                 f.destroy(1000 * 3);
             }
             this.indexFileList.clear();
         } catch (Exception e) {
             log.error("destroy exception", e);
         } finally {
-            this.readWriteLock.readLock().unlock();
+            this.readWriteLock.writeLock().unlock();
         }
     }