searcher pool init

binding/java/src/main/java/org/lionsoul/ip2region/SearcherPool.java

@@ -4,8 +4,11 @@
 
 package org.lionsoul.ip2region;
 
+import java.io.IOException;
 import java.util.LinkedList;
 import java.util.Queue;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.locks.ReentrantLock;
 
 import org.lionsoul.ip2region.xdb.Searcher;
 
@@ -22,12 +25,37 @@ public class SearcherPool {
     // searcher pool
     private final Queue<Searcher> pool;
 
+    // searcher lock
+    private final ReentrantLock lock;
+
+    // searcher numbers that was loaned out
+    private final AtomicInteger loanCount;
+
     public SearcherPool(Config config) {
+        this(config, false);
+    }
+
+    public SearcherPool(Config config, boolean fair) {
         this.config = config;
         this.pool = new LinkedList<>();
+        this.lock = new ReentrantLock(fair);
+        this.loanCount = new AtomicInteger(0);
+    }
+
+    // init the searcher pool 
+    public void init() throws IOException {
+        for (int i = 0; i < config.searchers; i++) {
+            final Searcher searcher = new Searcher(config.ipVersion, config.xdbPath, config.vIndex, config.cBuffer);
+            pool.add(searcher);
+        }
     }
 
     public Searcher getSearcher() {
         return null;
     }
+
+    // close the searcher pool
+    public void close() {
+        this.loanCount.set(config.searchers);
+    }
 }