Functions — github.com/Java-Edge/Java-Concurrency-Progamming-Tutorial

hub / github.com/Java-Edge/Java-Concurrency-Progamming-Tutorial / functions

Functions359 in github.com/Java-Edge/Java-Concurrency-Progamming-Tutorial

⨍ Functions 359◇ Types & classes 176

↓ 59 callersMethodexecute

提交任务

src/main/java/com/javaedge/concurrency/threadpool/MyThreadPool.java:41

↓ 32 callersMethodget

()

src/main/java/com/javaedge/concurrency/lock/LockTest2.java:14

↓ 28 callersMethodput

(String key, Data value)

src/main/java/com/javaedge/concurrency/lock/LockExample3.java:40

↓ 26 callersMethodgetName

()

src/main/java/com/javaedge/concurrency/aqs/semaphore/MicrowaveOvenPool.java:24

↓ 23 callersMethodunlock

(int myTicket)

src/main/java/com/javaedge/concurrency/lock/TicketLock.java:20

↓ 17 callersMethodlock

()

src/main/java/com/javaedge/concurrency/lock/TicketLock.java:9

↓ 17 callersMethodtoString

()

src/main/java/com/javaedge/concurrency/cas/demo/Node.java:16

↓ 10 callersMethodadd

()

src/main/java/com/javaedge/concurrency/lock/LockDemo.java:13

↓ 8 callersMethodsave

(Integer r)

src/main/java/com/javaedge/concurrency/furure/jdk/CompletionServiceDemo.java:129

↓ 7 callersMethodadd

()

src/main/java/com/javaedge/concurrency/count/CountExample4.java:44

↓ 7 callersMethodremove

()

src/main/java/com/javaedge/concurrency/threadLocal/RequestHolder.java:20

↓ 6 callersMethodget

(String key)

src/main/java/com/javaedge/concurrency/cache/RedisClient.java:30

↓ 6 callersMethodget

()

src/main/java/com/javaedge/concurrency/common/stop/PrimeGenerator.java:45

↓ 5 callersMethodlock

()

src/main/java/com/javaedge/concurrency/aqs/SimpleLock.java:26

↓ 5 callersMethodpop

为了演示ABA效果，增加一个CAS操作的延时 @param time @return @throws InterruptedException

src/main/java/com/javaedge/concurrency/cas/demo/Stack.java:37

↓ 5 callersMethodpush

(Node node)

src/main/java/com/javaedge/concurrency/cas/demo/Stack.java:20

↓ 5 callersMethodset

(String key, String value)

src/main/java/com/javaedge/concurrency/cache/RedisClient.java:18

↓ 5 callersMethodunlock

()

src/main/java/com/javaedge/concurrency/aqs/SimpleLock.java:30

↓ 4 callersMethodadd

信号量保证互斥

src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample6.java:20

↓ 4 callersMethodprint

()

src/main/java/com/javaedge/concurrency/common/stop/StopThread.java:25

↓ 4 callersMethodtestCommon

测试：提交15个执行时间需要3秒的任务,看线程池的状况 @param threadPoolExecutor 传入不同的线程池，看不同的结果 @throws Exception

src/main/java/com/javaedge/concurrency/threadpool/ThreadPoolExample5.java:27

↓ 3 callersMethodcallback

(Boolean result)

src/main/java/com/javaedge/concurrency/furure/jdk/CompletableFutureDemo.java:50

↓ 3 callersMethodduration

()

src/main/java/com/javaedge/concurrency/common/Timer.java:11

↓ 3 callersMethodgetId

()

src/main/java/com/javaedge/concurrency/threadLocal/RequestHolder.java:16

↓ 3 callersMethodgetStates

()

src/main/java/com/javaedge/concurrency/publish/UnsafePublish.java:14

↓ 3 callersMethodisDone

RPC结果是否已经返回 @return

src/main/java/com/javaedge/concurrency/condition/DubboCondition.java:66

↓ 3 callersMethodtimeTest

(String id, long checkValue, LongSupplier operation)

src/main/java/com/javaedge/concurrency/streams/Summing.java:12

↓ 2 callersMethodadd

(Long id)

src/main/java/com/javaedge/concurrency/threadLocal/RequestHolder.java:12

↓ 2 callersMethodexecute

处理请求

src/main/java/workerthread/v1/Request.java:28

↓ 2 callersMethodget

()

src/main/java/com/javaedge/concurrency/cas/demo/ConcurrentStack.java:46

↓ 2 callersMethodgetInstance

()

src/main/java/com/javaedge/concurrency/singleton/SingletonExample6.java:25

↓ 2 callersMethodgetThreadName

()

src/main/java/com/javaedge/concurrency/furure/jdk/CompletableFurureDemo3.java:58

↓ 2 callersMethodgetWarmTime

()

src/main/java/com/javaedge/concurrency/aqs/semaphore/MicrowaveOvenPool.java:28

↓ 2 callersMethodmerge

(long[] left, long[] right)

src/main/java/com/javaedge/concurrency/forkjoin/ForkJoinTaskExample3.java:154

↓ 2 callersMethodtest1

()

src/main/java/com/javaedge/concurrency/sync/ObjectSyncDemo1.java:14

↓ 2 callersMethodtest1

(int j)

src/main/java/com/javaedge/concurrency/sync/SynchronizedExample2.java:18

↓ 2 callersMethodtest2

修饰一个方法 @param j

src/main/java/com/javaedge/concurrency/sync/SynchronizedExample1.java:34

↓ 2 callersMethodtryAcquire

(int ignore)

src/main/java/com/javaedge/concurrency/aqs/SimpleLock.java:8

↓ 1 callersMethodaSecondOfPrimes

()

src/main/java/com/javaedge/concurrency/common/stop/PrimeGenerator.java:49

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/ConcurrencyTest.java:47

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/lock/LockExample1.java:48

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/lock/LockExample2.java:48

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/lock/LockExample5.java:50

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/atomic/LockCASDemo.java:40

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/atomic/AtomicExample1.java:45

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/atomic/AtomicExample3.java:45

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/atomic/AtomicExample2.java:45

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/count/CountExample3.java:44

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/count/CountExample2.java:45

↓ 1 callersMethodadd

()

src/main/java/com/javaedge/concurrency/count/CountExample1.java:44

↓ 1 callersMethodcalc

(String line)

src/main/java/com/javaedge/concurrency/forkjoin/ForkJoinTaskExample3.java:101

↓ 1 callersMethodcancel

()

src/main/java/com/javaedge/concurrency/common/stop/PrimeGenerator.java:41

↓ 1 callersMethodcountUp

()

src/main/java/AppendixA/MyFrame.java:30

↓ 1 callersMethodexec

利用对象池的对象，调用func

src/main/java/com/javaedge/concurrency/aqs/semaphore/ObjPool.java:37

↓ 1 callersMethodgetPrice1

()

src/main/java/com/javaedge/concurrency/furure/jdk/CompletionServiceDemo.java:141

↓ 1 callersMethodgetPrice2

()

src/main/java/com/javaedge/concurrency/furure/jdk/CompletionServiceDemo.java:137

↓ 1 callersMethodgetPrice3

()

src/main/java/com/javaedge/concurrency/furure/jdk/CompletionServiceDemo.java:133

↓ 1 callersMethodmerge

合并结果 @param r1 @param r2 @return

src/main/java/com/javaedge/concurrency/forkjoin/ForkJoinTaskExample3.java:83

↓ 1 callersMethodputRequest

将请求放入队列 @param request

src/main/java/workerthread/v1/Channel.java:56

↓ 1 callersMethodrace

(int threadNum)

src/main/java/com/javaedge/concurrency/aqs/CyclicBarrierExample3.java:34

↓ 1 callersMethodrace

(int threadNum)

src/main/java/com/javaedge/concurrency/aqs/CyclicBarrierExample1.java:32

↓ 1 callersMethodrace

(int threadNum)

src/main/java/com/javaedge/concurrency/aqs/CyclicBarrierExample2.java:33

↓ 1 callersMethodrun

()

src/main/java/com/javaedge/concurrency/UnsafeTest.java:25

↓ 1 callersMethodrun

()

src/main/java/com/javaedge/concurrency/common/stop/StopThread.java:10

↓ 1 callersMethodstartWorkers

()

src/main/java/workerthread/v1/Channel.java:45

↓ 1 callersMethodstep

()

src/main/java/com/javaedge/concurrency/furure/jdk/Machina.java:14

↓ 1 callersMethodtakeRequest

取出队列中的请求 @return

src/main/java/workerthread/v1/Channel.java:74

↓ 1 callersMethodtest

(int threadNum)

src/main/java/com/javaedge/concurrency/aqs/CountDownLatchExample2.java:38

↓ 1 callersMethodtest

(int threadNum)

src/main/java/com/javaedge/concurrency/aqs/CountDownLatchExample1.java:37

↓ 1 callersMethodtest

(int threadNum)

src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample4.java:37

↓ 1 callersMethodtest

(int threadNum)

src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample2.java:35

↓ 1 callersMethodtest

(int threadNum)

src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample1.java:38

↓ 1 callersMethodtest

(int threadNum)

src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample3.java:36

↓ 1 callersMethodtest

()

src/main/java/com/javaedge/concurrency/atomic/AtomicExample6.java:45

↓ 1 callersMethodtest0

()

src/main/java/com/javaedge/concurrency/furure/jdk/CompletionServiceDemo.java:24

↓ 1 callersMethodtest1

(Vector<Integer> v1)

src/main/java/com/javaedge/concurrency/syncContainer/VectorExample3.java:9

↓ 1 callersMethodtest1

(Object arg)

src/main/java/com/javaedge/concurrency/sync/ObjectSyncDemo4.java:19

↓ 1 callersMethodtest1

(Object arg)

src/main/java/com/javaedge/concurrency/sync/ObjectSyncDemo3.java:8

↓ 1 callersMethodtest1

(Object arg)

src/main/java/com/javaedge/concurrency/sync/ObjectSyncDemo2.java:6

↓ 1 callersMethodtestAtomic

()

src/main/java/com/javaedge/concurrency/atomic/LongAdderDemo.java:39

↓ 1 callersMethodtestLongAdder

()

src/main/java/com/javaedge/concurrency/atomic/LongAdderDemo.java:54

↓ 1 callersMethodtestSync

同步代码块的方式 @throws InterruptedException

src/main/java/com/javaedge/concurrency/atomic/LongAdderDemo.java:19

↓ 1 callersMethodtoString

()

src/main/java/com/javaedge/concurrency/furure/jdk/Machina.java:38

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/syncContainer/CollectionsExample1.java:48

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/syncContainer/HashTableExample.java:47

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/syncContainer/VectorExample1.java:47

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/syncContainer/CollectionsExample2.java:48

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/syncContainer/CollectionsExample3.java:48

↓ 1 callersMethodupdate

()

src/main/java/com/javaedge/concurrency/commonunsafe/DateFormatExample1.java:44

↓ 1 callersMethodupdate

()

src/main/java/com/javaedge/concurrency/commonunsafe/DateFormatExample2.java:42

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/commonunsafe/ArrayListExample.java:47

↓ 1 callersMethodupdate

()

src/main/java/com/javaedge/concurrency/commonunsafe/StringExample1.java:44

↓ 1 callersMethodupdate

()

src/main/java/com/javaedge/concurrency/commonunsafe/StringExample2.java:47

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/commonunsafe/HashMapExample.java:47

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/commonunsafe/DateFormatExample3.java:47

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/commonunsafe/HashSetExample.java:47

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/concurrent/CopyOnWriteArrayListExample.java:47

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/concurrent/CopyOnWriteArraySetExample.java:47

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/concurrent/ConcurrentSkipListMapExample.java:47

↓ 1 callersMethodupdate

(int i)

src/main/java/com/javaedge/concurrency/concurrent/ConcurrentSkipListSetExample.java:47

next →1–100 of 359, ranked by callers