MCPcopy Create free account

hub / github.com/appleappleapple/DistributeLearning / functions

Functions169 in github.com/appleappleapple/DistributeLearning

↓ 77 callersMethodreturnResource
���������ӳ� @param pool @param jedis
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1860
↓ 15 callersMethodexists
<p> �ж�key�Ƿ���� </p> @param key @return true OR false
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:163
↓ 10 callersMethodget
<p> ͨ��key��ȡ������redis�е�value </p> <p> ���ͷ����� </p> @param key @return �ɹ�����value ʧ�ܷ���null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:67
↓ 7 callersMethodgetInstance
()
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:52
↓ 6 callersMethodgetJedis
()
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:47
↓ 6 callersMethodisTimeExpired
(String value)
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:146
↓ 5 callersMethoddel
<p> ɾ��ָ����key,Ҳ���Դ���һ������key������ </p> @param keys һ��key Ҳ����ʹ string ���� @return ����ɾ���ɹ��ĸ���
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:116
↓ 5 callersMethodsetExclusiveOwnerThread
(Thread thread)
src/main/java/com/github/distribute/lock/redis/AbstractLock.java:64
↓ 4 callersMethodset
<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 callersMethodsize
��ȡ���еĴ�С @return @throws Exception
src/main/java/com/github/distribute/queue/DistributedQueue.java:69
↓ 3 callersMethodisEmpty
�ж϶����Ƿ�Ϊ�� @return @throws Exception
src/main/java/com/github/distribute/queue/DistributedQueue.java:79
↓ 3 callersMethodlock
()
src/main/java/com/github/distribute/lock/redis/AbstractLock.java:27
↓ 2 callersMethodattemptLock
���Ի�ȡ����������ӳ�ʱʱ�䣬�����ȴ������򣬾��Ǽ��˳�ʱ�������ȴ� @param time @param unit @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:220
↓ 2 callersMethodcheckInterruption
()
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:140
↓ 2 callersMethodgetLockNodeNumber
ȡ����������� @param str @param lockName @return
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:78
↓ 2 callersMethodgetLockNodeNumber
ȡ����������� @param str @param lockName @return
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:54
↓ 2 callersMethodgetNodeNumber
(String str, String nodeName)
src/main/java/com/github/distribute/queue/DistributedSimpleQueue.java:113
↓ 2 callersMethodgetNodeNumber
��ȡ�ڵ�����ֵķ��� @param str @param nodeName @return
src/main/java/com/github/distribute/queue/DistributedQueue.java:247
↓ 2 callersMethodgetSortedChildren
ȡ�����������б� @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:93
↓ 2 callersMethodsadd
<p> ͨ��key��ָ����set������value </p> @param key @param members ������һ��String Ҳ������һ��String���� @return ���ӳɹ��ĸ���
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1129
↓ 2 callersMethodsetnx
<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 callersMethodsize
()
src/main/java/com/github/distribute/queue/DistributedSimpleQueue.java:37
↓ 2 callersMethodsmembers
<p> ͨ��key��ȡset�����е�value </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1452
↓ 2 callersMethodunLock
()
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:283
↓ 1 callersMethodByteToObject
bytes תobject @param bytes @return
src/main/java/com/github/distribute/queue/DistributedQueue.java:89
↓ 1 callersMethodObjectToByte
Object תbyte @param obj @return
src/main/java/com/github/distribute/queue/DistributedQueue.java:112
↓ 1 callersMethodcreateLockNode
createLockNode������locker��basePath�־ýڵ㣩�´����ͻ���Ҫ��ȡ����[��ʱ]˳��ڵ� @param path @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:203
↓ 1 callersMethodcreateLockNode
createLockNode������locker��basePath�־ýڵ㣩�´����ͻ���Ҫ��ȡ����[��ʱ]˳��ڵ� @param path @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:191
↓ 1 callersMethoddecr
<p> ��key��ֵ����������,���key������,������keyΪ-1 </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:460
↓ 1 callersMethoddeleteLockNode
ɾ�����ڵ�
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:85
↓ 1 callersMethoddoUnlock
()
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:154
↓ 1 callersMethodexport
(final Object service, final Class interfaceClazz, int port)
src/main/java/com/github/distribute/rpc/RpcFramework.java:13
↓ 1 callersMethodgetExclusiveOwnerThread
()
src/main/java/com/github/distribute/lock/redis/AbstractLock.java:68
↓ 1 callersMethodgetSortedChildren
ȡ�����������б� @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:69
↓ 1 callersMethodhello
()
src/main/java/com/github/distribute/rpc/HelloService.java:5
↓ 1 callersMethodinit
��ʼ����Ŀ¼
src/main/java/com/github/distribute/queue/DistributedQueue.java:51
↓ 1 callersMethodinit
()
src/main/java/com/github/distribute/lock/redis/PessimisticLockTest.java:104
↓ 1 callersMethodinit
��ʼ����Ŀ¼
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:60
↓ 1 callersMethodinitClient
()
src/main/java/com/github/distribute/lock/redis/PessimisticLockTest.java:42
↓ 1 callersMethodinitClient
()
src/main/java/com/github/distribute/lock/redis/OptimisticLockTest.java:49
↓ 1 callersMethodinitPrduct
��ʼ����Ʒ����
src/main/java/com/github/distribute/lock/redis/PessimisticLockTest.java:66
↓ 1 callersMethodinitPrduct
��ʼ����Ʒ����
src/main/java/com/github/distribute/lock/redis/OptimisticLockTest.java:73
↓ 1 callersMethodinvoke
(Object proxy, Method method, Object[] args)
src/main/java/com/github/distribute/rpc/RpcFramework.java:95
↓ 1 callersMethodisTimeout
(long start, long timeout)
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:150
↓ 1 callersMethodlock
()
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:265
↓ 1 callersMethodoffer
������ṩ����,�������Ļ��������ȴ�ֱ��start��־λ��� @param element @return @throws Exception
src/main/java/com/github/distribute/queue/DistributedQueue.java:138
↓ 1 callersMethodpoll
�Ӷ���ȡ����,����start��־λʱ����ʼȡ���ݣ�ȫ��ȡ�����ݺ��ɾ��start��־ @return @throws Exception
src/main/java/com/github/distribute/queue/DistributedQueue.java:187
↓ 1 callersMethodprintResult
������
src/main/java/com/github/distribute/lock/redis/PessimisticLockTest.java:27
↓ 1 callersMethodprintResult
������
src/main/java/com/github/distribute/lock/redis/OptimisticLockTest.java:34
↓ 1 callersMethodrefer
(final Class<T> interfaceClass, final String host, final int port)
src/main/java/com/github/distribute/rpc/RpcFramework.java:77
↓ 1 callersMethodtryLock
���Ի�ȡ��,�����еȴ����õ�����true, @return @throws Exception
src/main/java/com/github/distribute/lock/DistributedLock.java:13
↓ 1 callersMethodunlock
()
src/main/java/com/github/distribute/lock/redis/AbstractLock.java:54
↓ 1 callersMethodunlock0
()
src/main/java/com/github/distribute/lock/redis/AbstractLock.java:72
↓ 1 callersMethodwaitToLock
�÷��������ж��Լ��Ƿ��ȡ�����������Լ�������˳��ڵ���locker�������ӽڵ����Ƿ���С.���û�л�ȡ��������ȴ������ͻ��������ͷţ� �����Ժ�����ֱ����ȡ�������߳�ʱ @param startMi
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:116
↓ 1 callersMethodwaitToLock
�÷��������ж��Լ��Ƿ��ȡ�����������Լ�������˳��ڵ���locker�������ӽڵ����Ƿ���С.���û�л�ȡ��������ȴ������ͻ��������ͷţ� �����Ժ�����ֱ����ȡ�������߳�ʱ @param startMi
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:104
MethodClientThread
(int num)
src/main/java/com/github/distribute/lock/redis/OptimisticLockTest.java:105
MethodConsumerThread
(DistributedSimpleQueue<SendObject> queue)
src/main/java/com/github/distribute/queue/DistributedQueueTest.java:23
MethodDistributedQueue
(ZooKeeper zooKeeper, String root, int queueSize)
src/main/java/com/github/distribute/queue/DistributedQueue.java:41
MethodDistributedSimpleQueue
(ZkClient zkClient, String root)
src/main/java/com/github/distribute/queue/DistributedSimpleQueue.java:31
MethodPessClientThread
(int num)
src/main/java/com/github/distribute/lock/redis/PessimisticLockTest.java:99
MethodProducerThread
(DistributedSimpleQueue<SendObject> queue)
src/main/java/com/github/distribute/queue/DistributedQueueTest.java:43
MethodRedisBasedDistributedLock
(Jedis jedis, String lockKey, long lockExpires)
src/main/java/com/github/distribute/lock/redis/RedisBasedDistributedLock.java:23
MethodRedisUtil
()
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:29
MethodSendObject
(String id, String content)
src/main/java/com/github/distribute/queue/DistributedQueueTest.java:65
MethodZookeeperDistributeLock
(ZooKeeper zookeeper, String rootPath, String lockNamePre)
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:49
Methodappend
<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
MethodattemptLock
���Ի�ȡ����������ӳ�ʱʱ�䣬�����ȴ������򣬾��Ǽ��˳�ʱ�������ȴ� @param time @param unit @return @throws Exception
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:208
Methodcompare
(String lhs, String rhs)
src/main/java/com/github/distribute/queue/DistributedSimpleQueue.java:84
Methodcompare
(String lhs, String rhs)
src/main/java/com/github/distribute/queue/DistributedQueue.java:215
Methodcompare
(String lhs, String rhs)
src/main/java/com/github/distribute/lock/zookeeper/ZookeeperDistributeLock.java:97
Methodcompare
(String lhs, String rhs)
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:73
MethoddecrBy
<p> ��ȥָ����ֵ </p> @param key @param integer @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:484
MethodgetContent
()
src/main/java/com/github/distribute/queue/DistributedQueueTest.java:82
MethodgetId
()
src/main/java/com/github/distribute/queue/DistributedQueueTest.java:74
Methodgetrange
<p> ͨ���±� ��key ��ȡָ���±�λ�õ� value </p> @param key @param startOffset ��ʼλ�� ��0 ��ʼ ������ʾ���ұ߿�ʼ��ȡ @param endOffset @return ���û�з��
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:390
Methodgetset
<p> ����key��ֵ,������һ����ֵ </p> @param key @param value @return ��ֵ ���key������ �򷵻�null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:364
Methodhdel
<p> ͨ��key ɾ��ָ���� field </p> @param key @param fields ������ һ�� field Ҳ������ һ������ @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:729
Methodhello
()
src/main/java/com/github/distribute/rpc/HelloServiceImpl.java:6
Methodhexists
<p> ͨ��key��field�ж��Ƿ���ָ����value���� </p> @param key @param field @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:680
Methodhget
<p> ͨ��key �� field ��ȡָ���� value </p> @param key @param field @return û�з���null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:606
Methodhgetall
<p> ͨ��key��ȡ���е�field��value </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:798
Methodhincrby
<p> ͨ��key��ָ����field��value���ϸ�����ֵ </p> @param key @param field @param value @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:656
Methodhkeys
<p> ͨ��key�������е�field </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:752
Methodhlen
<p> ͨ��key����field������ </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:703
Methodhmget
<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
Methodhmset
<p> ͨ��keyͬʱ���� hash�Ķ��field </p> @param key @param hash @return ����OK �쳣����null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:582
Methodhset
<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
Methodhsetnx
<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
Methodhvals
<p> ͨ��key�������к�key�йص�value </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:775
Methodincr
<p> ͨ��key ��value���м�ֵ+1����,��value����int����ʱ�᷵�ش���,��key����������valueΪ1 </p> @param key @return ��ֵ��Ľ��
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:413
MethodincrBy
<p> ͨ��key��ָ����value��ֵ,���key������,������valueΪ��ֵ </p> @param key @param integer @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:437
Methodinit
��ʼ����Ŀ¼
src/main/java/com/github/distribute/lock/zookeeper/BaseDistributedLock.java:36
MethodisEmpty
()
src/main/java/com/github/distribute/queue/DistributedSimpleQueue.java:45
MethodisLocked
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
Methodkeys
<p> ��������pattern����ʽ������key </p> <p> keys( ) </p> <p> �������е�key </p> @param pattern @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1816
Methodlindex
<p> ͨ��key��ȡlist��ָ���±�λ�õ�value </p> @param key @param index @return ���û�з���null
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1053
Methodlinsert
<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
Methodllen
<p> ͨ��key����list�ij��� </p> @param key @return
src/main/java/com/github/distribute/lock/redis/RedisUtil.java:1076
Methodlock
�����ȴ���ȡ�� @throws Exception
src/main/java/com/github/distribute/lock/DistributedLock.java:20
Methodlock
(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