Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/appleappleapple/DistributeLearning
/ functions
Functions
169 in github.com/appleappleapple/DistributeLearning
⨍
Functions
169
◇
Types & classes
21
↓ 77 callers
Method
returnResource
���������ӳ� @param pool @param jedis
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1860
↓ 15 callers
Method
exists
<p> �ж�key�Ƿ���� </p> @param key @return true OR false
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:163
↓ 10 callers
Method
get
<p> ͨ��key��ȡ������redis�е�value </p> <p> ���ͷ����� </p> @param key @return �ɹ�����value ʧ�ܷ���null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:67
↓ 7 callers
Method
getInstance
()
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:52
↓ 6 callers
Method
getJedis
()
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:47
↓ 6 callers
Method
isTimeExpired
(String value)
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:146
↓ 5 callers
Method
del
<p> ɾ��ָ����key,Ҳ���Դ���һ������key������ </p> @param keys һ��key Ҳ����ʹ string ���� @return ����ɾ���ɹ��ĸ���
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:116
↓ 5 callers
Method
setExclusiveOwnerThread
(Thread thread)
src/main/java/com/github/distribute/lock/redis/AbstractLock.java:64
↓ 4 callers
Method
set
<p> ��redis����key��value,���ͷ�������Դ </p> <p> ���key�Ѿ����� �� </p> @param key @param value @return �ɹ� ����OK ʧ�ܷ��� 0
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:93
↓ 4 callers
Method
size
��ȡ���еĴ�С @return @throws Exception
src/main/java/com/github/distribute/queue/DistributedQueue.java:69
↓ 3 callers
Method
isEmpty
�ж϶����Ƿ�Ϊ�� @return @throws Exception
src/main/java/com/github/distribute/queue/DistributedQueue.java:79
↓ 3 callers
Method
lock
()
src/main/java/com/github/distribute/lock/redis/AbstractLock.java:27
↓ 2 callers
Method
attemptLock
���Ի�ȡ����������ӳ�ʱʱ�䣬�����ȴ��������Ǽ��˳�ʱ�������ȴ� @param time @param unit @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:220
↓ 2 callers
Method
checkInterruption
()
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:140
↓ 2 callers
Method
getLockNodeNumber
ȡ����������� @param str @param lockName @return
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:78
↓ 2 callers
Method
getLockNodeNumber
ȡ����������� @param str @param lockName @return
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:54
↓ 2 callers
Method
getNodeNumber
(String str, String nodeName)
src/main/java/com/github/distribute/queue/DistributedSimpleQueue.java:113
↓ 2 callers
Method
getNodeNumber
��ȡ�ڵ�����ֵķ��� @param str @param nodeName @return
src/main/java/com/github/distribute/queue/DistributedQueue.java:247
↓ 2 callers
Method
getSortedChildren
ȡ�����������б� @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:93
↓ 2 callers
Method
sadd
<p> ͨ��key��ָ����set������value </p> @param key @param members ������һ��String Ҳ������һ��String���� @return ���ӳɹ��ĸ���
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1129
↓ 2 callers
Method
setnx
<p> ����key value,���key�Ѿ�������0,nx==> not exist </p> @param key @param value @return �ɹ�����1 ������� �� �����쳣 ���� 0
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:186
↓ 2 callers
Method
size
()
src/main/java/com/github/distribute/queue/DistributedSimpleQueue.java:37
↓ 2 callers
Method
smembers
<p> ͨ��key��ȡset�����е�value </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1452
↓ 2 callers
Method
unLock
()
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:283
↓ 1 callers
Method
ByteToObject
bytes תobject @param bytes @return
src/main/java/com/github/distribute/queue/DistributedQueue.java:89
↓ 1 callers
Method
ObjectToByte
Object תbyte @param obj @return
src/main/java/com/github/distribute/queue/DistributedQueue.java:112
↓ 1 callers
Method
createLockNode
createLockNode������locker��basePath�־ýڵ㣩�´����ͻ���Ҫ��ȡ����[��ʱ]˳��ڵ� @param path @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:203
↓ 1 callers
Method
createLockNode
createLockNode������locker��basePath�־ýڵ㣩�´����ͻ���Ҫ��ȡ����[��ʱ]˳��ڵ� @param path @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:191
↓ 1 callers
Method
decr
<p> ��key��ֵ����������,���key������,������keyΪ-1 </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:460
↓ 1 callers
Method
deleteLockNode
ɾ�����ڵ�
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:85
↓ 1 callers
Method
doUnlock
()
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:154
↓ 1 callers
Method
export
(final Object service, final Class interfaceClazz, int port)
src/main/java/com/github/distribute/rpc/RpcFramework.java:13
↓ 1 callers
Method
getExclusiveOwnerThread
()
src/main/java/com/github/distribute/lock/redis/AbstractLock.java:68
↓ 1 callers
Method
getSortedChildren
ȡ�����������б� @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:69
↓ 1 callers
Method
hello
()
src/main/java/com/github/distribute/rpc/HelloService.java:5
↓ 1 callers
Method
init
��ʼ����Ŀ¼
src/main/java/com/github/distribute/queue/DistributedQueue.java:51
↓ 1 callers
Method
init
()
src/main/java/com/github/distribute/lock/redis/PessimisticLockTest.java:104
↓ 1 callers
Method
init
��ʼ����Ŀ¼
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:60
↓ 1 callers
Method
initClient
()
src/main/java/com/github/distribute/lock/redis/PessimisticLockTest.java:42
↓ 1 callers
Method
initClient
()
src/main/java/com/github/distribute/lock/redis/OptimisticLockTest.java:49
↓ 1 callers
Method
initPrduct
��ʼ����Ʒ����
src/main/java/com/github/distribute/lock/redis/PessimisticLockTest.java:66
↓ 1 callers
Method
initPrduct
��ʼ����Ʒ����
src/main/java/com/github/distribute/lock/redis/OptimisticLockTest.java:73
↓ 1 callers
Method
invoke
(Object proxy, Method method, Object[] args)
src/main/java/com/github/distribute/rpc/RpcFramework.java:95
↓ 1 callers
Method
isTimeout
(long start, long timeout)
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:150
↓ 1 callers
Method
lock
()
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:265
↓ 1 callers
Method
offer
������ṩ����,�������Ļ��������ȴ�ֱ��start��־λ��� @param element @return @throws Exception
src/main/java/com/github/distribute/queue/DistributedQueue.java:138
↓ 1 callers
Method
poll
�Ӷ���ȡ����,����start��־λʱ����ʼȡ���ݣ�ȫ��ȡ�����ݺ��ɾ��start��־ @return @throws Exception
src/main/java/com/github/distribute/queue/DistributedQueue.java:187
↓ 1 callers
Method
printResult
������
src/main/java/com/github/distribute/lock/redis/PessimisticLockTest.java:27
↓ 1 callers
Method
printResult
������
src/main/java/com/github/distribute/lock/redis/OptimisticLockTest.java:34
↓ 1 callers
Method
refer
(final Class<T> interfaceClass, final String host, final int port)
src/main/java/com/github/distribute/rpc/RpcFramework.java:77
↓ 1 callers
Method
tryLock
���Ի�ȡ��,�����еȴ����õ�����true, @return @throws Exception
src/main/java/com/github/distribute/lock/DistributedLock.java:13
↓ 1 callers
Method
unlock
()
src/main/java/com/github/distribute/lock/redis/AbstractLock.java:54
↓ 1 callers
Method
unlock0
()
src/main/java/com/github/distribute/lock/redis/AbstractLock.java:72
↓ 1 callers
Method
waitToLock
�÷��������ж��Լ��Ƿ��ȡ�����������Լ�������˳��ڵ���locker�������ӽڵ����Ƿ���С.���û�л�ȡ��������ȴ������ͻ��������ͷţ� �����Ժ�����ֱ����ȡ�������߳�ʱ @param startMi
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:116
↓ 1 callers
Method
waitToLock
�÷��������ж��Լ��Ƿ��ȡ�����������Լ�������˳��ڵ���locker�������ӽڵ����Ƿ���С.���û�л�ȡ��������ȴ������ͻ��������ͷţ� �����Ժ�����ֱ����ȡ�������߳�ʱ @param startMi
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:104
Method
ClientThread
(int num)
src/main/java/com/github/distribute/lock/redis/OptimisticLockTest.java:105
Method
ConsumerThread
(DistributedSimpleQueue<SendObject> queue)
src/main/java/com/github/distribute/queue/DistributedQueueTest.java:23
Method
DistributedQueue
(ZooKeeper zooKeeper, String root, int queueSize)
src/main/java/com/github/distribute/queue/DistributedQueue.java:41
Method
DistributedSimpleQueue
(ZkClient zkClient, String root)
src/main/java/com/github/distribute/queue/DistributedSimpleQueue.java:31
Method
PessClientThread
(int num)
src/main/java/com/github/distribute/lock/redis/PessimisticLockTest.java:99
Method
ProducerThread
(DistributedSimpleQueue<SendObject> queue)
src/main/java/com/github/distribute/queue/DistributedQueueTest.java:43
Method
RedisBasedDistributedLock
(Jedis jedis, String lockKey, long lockExpires)
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:23
Method
RedisUtil
()
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:29
Method
SendObject
(String id, String content)
src/main/java/com/github/distribute/queue/DistributedQueueTest.java:65
Method
ZookeeperDistributeLock
(ZooKeeper zookeeper, String rootPath, String lockNamePre)
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:49
Method
append
<p> ͨ��key��ָ����valueֵ��ֵ </p> @param key @param str @return �ɹ����� ���Ӻ�value�ij��� ʧ�� ���� ���ӵ� value �ij��� �쳣����0L
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:139
Method
attemptLock
���Ի�ȡ����������ӳ�ʱʱ�䣬�����ȴ��������Ǽ��˳�ʱ�������ȴ� @param time @param unit @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:208
Method
compare
(String lhs, String rhs)
src/main/java/com/github/distribute/queue/DistributedSimpleQueue.java:84
Method
compare
(String lhs, String rhs)
src/main/java/com/github/distribute/queue/DistributedQueue.java:215
Method
compare
(String lhs, String rhs)
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:97
Method
compare
(String lhs, String rhs)
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:73
Method
decrBy
<p> ��ȥָ����ֵ </p> @param key @param integer @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:484
Method
getContent
()
src/main/java/com/github/distribute/queue/DistributedQueueTest.java:82
Method
getId
()
src/main/java/com/github/distribute/queue/DistributedQueueTest.java:74
Method
getrange
<p> ͨ���±� ��key ��ȡָ���±�λ�õ� value </p> @param key @param startOffset ��ʼλ�� ��0 ��ʼ ������ʾ���ұ߿�ʼ��ȡ @param endOffset @return ���û�з��
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:390
Method
getset
<p> ����key��ֵ,������һ����ֵ </p> @param key @param value @return ��ֵ ���key������ ��null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:364
Method
hdel
<p> ͨ��key ɾ��ָ���� field </p> @param key @param fields ������ һ�� field Ҳ������ һ������ @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:729
Method
hello
()
src/main/java/com/github/distribute/rpc/HelloServiceImpl.java:6
Method
hexists
<p> ͨ��key��field�ж��Ƿ���ָ����value���� </p> @param key @param field @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:680
Method
hget
<p> ͨ��key �� field ��ȡָ���� value </p> @param key @param field @return û�з���null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:606
Method
hgetall
<p> ͨ��key��ȡ���е�field��value </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:798
Method
hincrby
<p> ͨ��key��ָ����field��value���ϸ�����ֵ </p> @param key @param field @param value @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:656
Method
hkeys
<p> ͨ��key�������е�field </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:752
Method
hlen
<p> ͨ��key����field������ </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:703
Method
hmget
<p> ͨ��key �� fields ��ȡָ����value ���û�ж�Ӧ��value��null </p> @param key @param fields ����ʹ һ��String Ҳ������ String���� @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:631
Method
hmset
<p> ͨ��keyͬʱ���� hash�Ķ��field </p> @param key @param hash @return ����OK �쳣����null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:582
Method
hset
<p> ͨ��key��field����ָ����ֵ,���key������,���ȴ��� </p> @param key @param field �ֶ� @param value @return ������ڷ���0 �쳣����null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:533
Method
hsetnx
<p> ͨ��key��field����ָ����ֵ,���key���������ȴ���,���field�Ѿ�����,����0 </p> @param key @param field @param value @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:558
Method
hvals
<p> ͨ��key�������к�key�йص�value </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:775
Method
incr
<p> ͨ��key ��value���м�ֵ+1����,��value����int����ʱ�᷵�ش���,��key����������valueΪ1 </p> @param key @return ��ֵ��Ľ��
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:413
Method
incrBy
<p> ͨ��key��ָ����value��ֵ,���key������,������valueΪ��ֵ </p> @param key @param integer @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:437
Method
init
��ʼ����Ŀ¼
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:36
Method
isEmpty
()
src/main/java/com/github/distribute/queue/DistributedSimpleQueue.java:45
Method
isLocked
Queries if this lock is held by any thread. @return {@code true} if any thread holds this lock and {@code false} otherwise
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:118
Method
keys
<p> ��������pattern����ʽ������key </p> <p> keys( ) </p> <p> �������е�key </p> @param pattern @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1816
Method
lindex
<p> ͨ��key��ȡlist��ָ���±�λ�õ�value </p> @param key @param index @return ���û�з���null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1053
Method
linsert
<p> ͨ��key��listָ����λ��֮ǰ����֮�� �����ַ���Ԫ�� </p> @param key @param where LIST_POSITIONö������ @param pivot list�����value @p
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:876
Method
llen
<p> ͨ��key����list�ij��� </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1076
Method
lock
�����ȴ���ȡ�� @throws Exception
src/main/java/com/github/distribute/lock/DistributedLock.java:20
Method
lock
(boolean useTimeout, long time, TimeUnit unit, boolean interrupt)
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:30
next →
1–100 of 169, ranked by callers