forked from lance-format/lance
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathLockManager.java
More file actions
68 lines (60 loc) · 1.86 KB
/
LockManager.java
File metadata and controls
68 lines (60 loc) · 1.86 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
/*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.lance;
import java.util.concurrent.locks.ReentrantReadWriteLock;
/** The LockManager class provides a way to manage read and write locks. */
public class LockManager {
private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
/**
* Represents a read lock for the LockManager. This lock allows multiple threads to read
* concurrently, but prevents write access.
*/
public class ReadLock implements AutoCloseable {
/** Acquires a read lock on the lock manager. */
public ReadLock() {
lock.readLock().lock();
}
@Override
public void close() {
lock.readLock().unlock();
}
}
/** Represents a write lock that can be acquired and released. */
public class WriteLock implements AutoCloseable {
/** Constructs a new WriteLock and acquires the write lock. */
public WriteLock() {
lock.writeLock().lock();
}
@Override
public void close() {
lock.writeLock().unlock();
}
}
/**
* Acquires a read lock on the LockManager.
*
* @return the acquired ReadLock object
*/
public ReadLock acquireReadLock() {
return new ReadLock();
}
/**
* Acquires a write lock on the LockManager.
*
* @return the acquired WriteLock object
*/
public WriteLock acquireWriteLock() {
return new WriteLock();
}
}