Functions — github.com/Fadezed/concurrency

CodeHub MCPcopy Create free account

hub / github.com/Fadezed/concurrency / functions

Functions277 in github.com/Fadezed/concurrency

⨍ Functions 277◇ Types & classes 110

MethodBlockedQueue

src/main/java/com/example/concurrency/patterns/blockingQueue/BlockedQueue.java:30

src/main/java/com/example/concurrency/features/jsr166e/Striped64.java:73

MethodControllableQueue

src/main/java/com/example/concurrency/features/threadPool/QueueAbleCachedThreadPool.java:93

MethodControlledInitialization

构造函数中实现完成加载过程

src/main/java/com/example/concurrency/patterns/resourcesinitialization/ControlledInitialization.java:82

MethodFinalExample

src/main/java/com/example/concurrency/features/finalcase/FinalExample.java:24

MethodLogbackListAppender

src/test/java/com/example/concurrency/LogbackListAppender.java:21

MethodLongAdder

Creates a new adder with initial sum of zero.

src/main/java/com/example/concurrency/features/jsr166e/LongAdder.java:59

MethodLongRunTask

(CountDownLatch countDownLatch)

src/test/java/com/example/concurrency/ThreadDumpHelperTest.java:27

MethodMyThreadPool

(int poolSize, BlockingQueue<Runnable> workQueue)

src/main/java/com/example/concurrency/features/threadPool/MyThreadPool.java:26

构造函数 @param size size @param t t

src/main/java/com/example/concurrency/features/semaphore/SemaphoreEx.java:57

MethodParallelSum

(List<BigInteger> bigIntegerList)

src/main/java/com/example/concurrency/patterns/divideconquer/ParallelDivideAndConquer.java:32

MethodQueueAbleCachedThreadPool

(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit,

src/main/java/com/example/concurrency/features/threadPool/QueueAbleCachedThreadPool.java:29

MethodResourcePool

(int poolSize, List<T> initializedResources)

src/main/java/com/example/concurrency/patterns/resourcepool/ResourcePool.java:22

MethodSafeAccount

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedConnection.java:115

MethodSafeRunnable

(Runnable runnable)

src/main/java/com/example/concurrency/features/threadPool/ThreadPoolUtil.java:93

src/main/java/com/example/concurrency/features/limiter/Sampler.java:23

MethodSingleton

私有无参构造保证唯一入口

src/main/java/com/example/concurrency/features/singleton/Singleton.java:18

MethodSortExeAccount

(int id, int balance)

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedResolveDeadLock.java:140

MethodStaticSingleton

src/main/java/com/example/concurrency/features/singleton/StaticSingleton.java:8

MethodStriped64

Package-private default constructor

src/main/java/com/example/concurrency/features/jsr166e/Striped64.java:131

MethodSynchronizedTransferAccount

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedConnection.java:56

(FutureTask<String> ft2)

src/main/java/com/example/concurrency/features/futuretask/FutureTaskEx.java:92

MethodTaskConvergence

src/main/java/com/example/concurrency/patterns/taskconvergence/TaskConvergence.java:46

MethodThreadDumpHelper

src/main/java/com/example/concurrency/util/ThreadDumpHelper.java:32

MethodTimeIntervalLimiter

(long interval, TimeUnit timeUnit)

src/main/java/com/example/concurrency/features/limiter/TimeIntervalLimiter.java:18

MethodUnsafeAccount

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedConnection.java:25

MethodWaitAndNotifyAllocator

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedResolveDeadLock.java:99

MethodWaitNotifyQueue

(List<String> messages)

src/main/java/com/example/concurrency/patterns/conditionqueues/WaitNotifyQueue.java:27

(CyclicBarrier cyclicBarrier)

src/main/java/com/example/concurrency/features/cyclicbarrier/CyclicBarrierEx.java:20

src/main/java/com/example/concurrency/features/visibility/Visibility.java:19

用信号量保证互斥 @throws InterruptedException ex

src/main/java/com/example/concurrency/features/semaphore/SemaphoreEx.java:30

实现 count+=1 @param newValue new

src/main/java/com/example/concurrency/features/atomic/SimulatedCompareAndSwap.java:17

MethodaddToRootLogger

将此appender添加到root logger中.

src/test/java/com/example/concurrency/LogbackListAppender.java:129

MethodafterExecute

(Runnable r, Throwable t)

src/main/java/com/example/concurrency/features/threadPool/QueueAbleCachedThreadPool.java:36

(Object from, Object to)

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedResolveDeadLock.java:101

src/main/java/com/example/concurrency/features/threadPool/ThreadPoolBuilder.java:229

src/main/java/com/example/concurrency/features/threadPool/ThreadPoolBuilder.java:272

src/main/java/com/example/concurrency/features/threadPool/ThreadPoolBuilder.java:350

src/main/java/com/example/concurrency/features/visibility/Visibility.java:45

src/main/java/com/example/concurrency/features/futuretask/FutureTaskEx.java:95

src/main/java/com/example/concurrency/features/futuretask/FutureTaskEx.java:114

src/main/java/com/example/concurrency/features/cyclicbarrier/CyclicBarrierGeekTime.java:17

MethodclearLogs

清除之前append的所有log.

src/test/java/com/example/concurrency/LogbackListAppender.java:106

src/main/java/com/example/concurrency/patterns/divideconquer/ParallelDivideAndConquer.java:36

MethodcontextLoads

src/test/java/com/example/concurrency/ConcurrencyApplicationTests.java:12

(Class<?> loggerClass)

src/test/java/com/example/concurrency/LogbackListAppender.java:25

MethodcyclicBarrier

返回CyclicBarrier，每条线程减1并等待，减到0时，所有线程继续运行

src/main/java/com/example/concurrency/util/ConcurrentUtil.java:39

Methoddecrement

Equivalent to {@code add(-1)}.

src/main/java/com/example/concurrency/features/jsr166e/LongAdder.java:94

src/main/java/com/example/concurrency/patterns/blockingQueue/BlockedQueue.java:62

MethoddistanceFromOrigin

计算到原点的距离 @return v

src/main/java/com/example/concurrency/features/readwritelock/StampedLockEx.java:60

MethoddoSomeOperation

多个对象锁操作例如银行转账 @param obj1 o1 @param obj2 o2

src/main/java/com/example/concurrency/patterns/lockordering/FixedLockOrdering.java:45

MethoddoubleValue

Returns the {@link #sum} as a {@code double} after a widening primitive conversion.

src/main/java/com/example/concurrency/features/jsr166e/LongAdder.java:201

入队 @param x x @throws InterruptedException ex

src/main/java/com/example/concurrency/patterns/blockingQueue/BlockedQueue.java:44

src/main/java/com/example/concurrency/features/threadPool/QueueAbleCachedThreadPool.java:48

MethodfairSemaphore

返回公平的信号量，先请求的线程先拿到信号量

src/main/java/com/example/concurrency/util/ConcurrentUtil.java:53

MethodfloatValue

Returns the {@link #sum} as a {@code float} after a widening primitive conversion.

src/main/java/com/example/concurrency/features/jsr166e/LongAdder.java:192

Version of plus for use in retryUpdate

src/main/java/com/example/concurrency/features/jsr166e/LongAdder.java:51

( Object from, Object to)

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedResolveDeadLock.java:112

修饰非静态方法锁对象为当前类的实例对象 this

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedExample.java:22

读 @param key key @return v

src/main/java/com/example/concurrency/features/readwritelock/CacheByReadWriteLock.java:53

按需加载 @param key key @return v

src/main/java/com/example/concurrency/features/readwritelock/CacheByReadWriteLock.java:68

MethodgetAnotherValue

src/main/java/com/example/concurrency/patterns/lockordering/FixedLockOrdering.java:31

MethodgetBalance

查看余额 @return balance

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedNoConnection.java:46

MethodgetCoderByS1

src/main/java/com/example/concurrency/features/completionservice/ExecutorCompletionServiceExample.java:57

MethodgetCoderByS2

src/main/java/com/example/concurrency/features/completionservice/ExecutorCompletionServiceExample.java:60

MethodgetCoderByS3

src/main/java/com/example/concurrency/features/completionservice/ExecutorCompletionServiceExample.java:63

MethodgetFirstMessage

返回之前append的第一个log的内容.

src/test/java/com/example/concurrency/LogbackListAppender.java:55

MethodgetInstance

src/main/java/com/example/concurrency/features/singleton/Singleton.java:21

MethodgetInstance

src/main/java/com/example/concurrency/features/singleton/StaticSingleton.java:13

MethodgetLastMessage

返回之前append的最后一个log的内容.

src/test/java/com/example/concurrency/LogbackListAppender.java:75

MethodgetLogsCount

返回Log的数量。

src/test/java/com/example/concurrency/LogbackListAppender.java:92

MethodgetPassword

查看密码 @return password

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedNoConnection.java:65

MethodhandleInterruptedException

纯粹为了提醒下处理InterruptedException的正确方式，除非你是在写不可中断的任务.

src/main/java/com/example/concurrency/util/ThreadUtil.java:43

Returns the {@link #sum} as an {@code int} after a narrowing primitive conversion.

src/main/java/com/example/concurrency/features/jsr166e/LongAdder.java:183

MethodjStackDumpTest

src/test/java/com/example/concurrency/features/threadPool/AbortPolicyWithReportTest.java:15

MethodlongAdder

返回没有激烈CAS冲突的LongAdder, 并发的＋1将在不同的Counter里进行，只在取值时将多个Counter求和. 为了保持JDK版本兼容性，统一采用移植版

src/main/java/com/example/concurrency/util/ConcurrentUtil.java:25

MethodlongValue

Equivalent to {@link #sum}. @return the sum

src/main/java/com/example/concurrency/features/jsr166e/LongAdder.java:174

(String[] args)

src/test/java/com/example/concurrency/dflockTest/SyncTest.java:15

(String[] args)

src/test/java/com/example/concurrency/dflockTest/RTTTest.java:18

(String[] args)

src/test/java/com/example/concurrency/dflockTest/StampedLockTest.java:15

(String[] args)

src/test/java/com/example/concurrency/dflockTest/LockTest.java:16

(String[] args)

src/test/java/com/example/concurrency/dflockTest/LongAdderTest.java:15

(String[] args)

src/main/java/com/example/concurrency/ConcurrencyApplication.java:12

(String[] args)

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedExample.java:54

(String[] args)

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedResolveDeadLock.java:167

(String[] args)

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedConnection.java:77

(String[] args)

src/main/java/com/example/concurrency/features/synchronizedcase/SynchronizedConnection.java:182

(String[] args)

src/main/java/com/example/concurrency/features/completionservice/ExecutorCompletionServiceExample.java:67

(String[] args)

src/main/java/com/example/concurrency/features/semaphore/SemaphoreEx.java:84

(String[] args)

src/main/java/com/example/concurrency/features/completablefuture/CompletableFutureExample.java:49

(String[] args)

src/main/java/com/example/concurrency/features/completablefuture/CompletableFutureExample.java:64

(String[] args)

src/main/java/com/example/concurrency/features/completablefuture/CompletableFutureExample.java:93

(String[] args)

src/main/java/com/example/concurrency/features/completablefuture/CompletableFutureExample.java:109

(String[] args)

src/main/java/com/example/concurrency/features/contentswitch/ContentSwitchTest.java:24

(String[] args)

src/main/java/com/example/concurrency/features/countdownlatch/CountDownLatchEx.java:18

(String[] args)

src/main/java/com/example/concurrency/features/volatilecase/VolatileExample.java:32

(String[] args)

src/main/java/com/example/concurrency/features/volatilecase/VolatileExample.java:83

(String[] args)

src/main/java/com/example/concurrency/features/finalcase/FinalExample.java:42

(String[] args)

src/main/java/com/example/concurrency/features/cyclicbarrier/CyclicBarrierGeekTime.java:21

(String[] args)

src/main/java/com/example/concurrency/features/cyclicbarrier/CyclicBarrierEx.java:37

← previous next →101–200 of 277, ranked by callers