本文整理了Java中org.apache.lucene.store.Lock.release()
方法的一些代码示例,展示了Lock.release()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Lock.release()
方法的具体详情如下:
包路径:org.apache.lucene.store.Lock
类名称:Lock
方法名:release
[英]Releases exclusive access.
[中]释放独占访问权限。
代码示例来源:origin: lucene/lucene
/** Release the write lock, if needed. */
protected void finalize() throws IOException {
if (writeLock != null) {
writeLock.release(); // release write lock
writeLock = null;
}
}
代码示例来源:origin: org.compass-project/compass
@Override
public void release() throws IOException {
lock.release();
}
代码示例来源:origin: lucene/lucene
/** Release the write lock, if needed. */
protected final void finalize() throws IOException {
if (writeLock != null) {
writeLock.release(); // release write lock
writeLock = null;
}
}
代码示例来源:origin: org.apache.lucene/com.springsource.org.apache.lucene
/** Release the write lock, if needed. */
protected void finalize() throws Throwable {
try {
if (writeLock != null) {
writeLock.release(); // release write lock
writeLock = null;
}
} finally {
super.finalize();
}
}
代码示例来源:origin: org.apache.lucene/lucene-core-jfrog
/** Release the write lock, if needed. */
protected void finalize() throws Throwable {
try {
if (writeLock != null) {
writeLock.release(); // release write lock
writeLock = null;
}
} finally {
super.finalize();
}
}
代码示例来源:origin: org.apache.lucene/com.springsource.org.apache.lucene
/** Release the write lock, if needed. */
protected void finalize() throws Throwable {
try {
if (writeLock != null) {
writeLock.release(); // release write lock
writeLock = null;
}
} finally {
super.finalize();
}
}
代码示例来源:origin: org.apache.lucene/lucene-core-jfrog
/** Release the write lock, if needed. */
protected void finalize() throws Throwable {
try {
if (writeLock != null) {
writeLock.release(); // release write lock
writeLock = null;
}
} finally {
super.finalize();
}
}
代码示例来源:origin: org.compass-project/compass
private void clearLocksIfNeeded() {
if (!maintainOrder) {
return;
}
for (Map.Entry<String, Lock> entry : orderLocks.entrySet()) {
try {
entry.getValue().release();
} catch (IOException e) {
logger.warn("Failed to release lock for sub index [" + entry.getKey() + "]", e);
}
}
orderLocks.clear();
}
代码示例来源:origin: org.apache.lucene/lucene-core-jfrog
/**
* Forcibly unlocks the index in the named directory.
* <P>
* Caution: this should only be used by failure recovery code,
* when it is known that no other process nor thread is in fact
* currently accessing this index.
* @deprecated Please use {@link IndexWriter#unlock(Directory)} instead
*/
public static void unlock(Directory directory) throws IOException {
directory.makeLock(IndexWriter.WRITE_LOCK_NAME).release();
}
代码示例来源:origin: lucene/lucene
/**
* Forcibly unlocks the index in the named directory.
* <P>
* Caution: this should only be used by failure recovery code,
* when it is known that no other process nor thread is in fact
* currently accessing this index.
*/
public static void unlock(Directory directory) throws IOException {
directory.makeLock(IndexWriter.WRITE_LOCK_NAME).release();
directory.makeLock(IndexWriter.COMMIT_LOCK_NAME).release();
}
}
代码示例来源:origin: org.apache.lucene/com.springsource.org.apache.lucene
/**
* Forcibly unlocks the index in the named directory.
* <P>
* Caution: this should only be used by failure recovery code,
* when it is known that no other process nor thread is in fact
* currently accessing this index.
*/
public static void unlock(Directory directory) throws IOException {
directory.makeLock(IndexWriter.WRITE_LOCK_NAME).release();
}
代码示例来源:origin: org.apache.lucene/lucene-core-jfrog
/**
* Forcibly unlocks the index in the named directory.
* <P>
* Caution: this should only be used by failure recovery code,
* when it is known that no other process nor thread is in fact
* currently accessing this index.
*/
public static void unlock(Directory directory) throws IOException {
directory.makeLock(IndexWriter.WRITE_LOCK_NAME).release();
}
代码示例来源:origin: org.apache.lucene/com.springsource.org.apache.lucene
/**
* Forcibly unlocks the index in the named directory.
* <P>
* Caution: this should only be used by failure recovery code,
* when it is known that no other process nor thread is in fact
* currently accessing this index.
* @deprecated Please use {@link IndexWriter#unlock(Directory)} instead
*/
public static void unlock(Directory directory) throws IOException {
directory.makeLock(IndexWriter.WRITE_LOCK_NAME).release();
}
代码示例来源:origin: org.apache.lucene/com.springsource.org.apache.lucene
private void acquireTestLock() throws IOException {
String randomLockName = "lucene-" + Long.toString(new Random().nextInt(), Character.MAX_RADIX) + "-test.lock";
Lock l = makeLock(randomLockName);
try {
l.obtain();
} catch (IOException e) {
IOException e2 = new IOException("Failed to acquire random test lock; please verify filesystem for lock directory '" + lockDir + "' supports locking");
e2.initCause(e);
throw e2;
}
l.release();
}
代码示例来源:origin: org.apache.lucene/lucene-core-jfrog
private void acquireTestLock() throws IOException {
String randomLockName = "lucene-" + Long.toString(new Random().nextInt(), Character.MAX_RADIX) + "-test.lock";
Lock l = makeLock(randomLockName);
try {
l.obtain();
} catch (IOException e) {
IOException e2 = new IOException("Failed to acquire random test lock; please verify filesystem for lock directory '" + lockDir + "' supports locking");
e2.initCause(e);
throw e2;
}
l.release();
}
代码示例来源:origin: org.apache.lucene/com.springsource.org.apache.lucene
public synchronized void release() throws IOException {
if (isLocked()) {
verify((byte) 0);
lock.release();
}
}
}
代码示例来源:origin: gncloud/fastcatsearch
@Override
public synchronized void release() throws IOException {
if (isLocked()) {
verify((byte) 0);
lock.release();
}
}
}
代码示例来源:origin: org.apache.lucene/lucene-core-jfrog
public synchronized void release() throws IOException {
if (isLocked()) {
verify((byte) 0);
lock.release();
}
}
}
代码示例来源:origin: lucene/lucene
/** Calls {@link #doBody} while <i>lock</i> is obtained. Blocks if lock
* cannot be obtained immediately. Retries to obtain lock once per second
* until it is obtained, or until it has tried ten times. Lock is released when
* {@link #doBody} exits. */
public Object run() throws IOException {
boolean locked = false;
try {
locked = lock.obtain(lockWaitTimeout);
return doBody();
} finally {
if (locked)
lock.release();
}
}
}
代码示例来源:origin: lucene/lucene
/** Flushes all changes to an index and closes all associated files. */
public synchronized void close() throws IOException {
flushRamSegments();
ramDirectory.close();
writeLock.release(); // release write lock
writeLock = null;
if(closeDir)
directory.close();
}
内容来源于网络,如有侵权,请联系作者删除!