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

(String[] args)

src/main/java/com/example/concurrency/features/exchanger/ExchangerExample.java:19

(String[] args)

src/main/java/com/example/concurrency/features/threadstate/ThreadState.java:15

(String[] args)

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

(String[] args)

src/main/java/com/example/concurrency/features/concurrenthashmap/ConcurrentHashMapTest.java:11

(String[] args)

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

(String[] args)

src/main/java/com/example/concurrency/features/atomic/AtomicCounter.java:19

(String[] args)

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

(String[] args)

src/main/java/com/example/concurrency/features/deadlock/DeadLockTest.java:31

(String[] args)

src/main/java/com/example/concurrency/patterns/taskcancel/ConsoleTimePrintTask.java:47

(String[] args)

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

(String[] args)

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

(String[] args)

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

通过两种方式验证一千万个数据的累加执行速度 @param args args @throws InterruptedException e

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

(String[] args)

src/main/java/com/example/concurrency/patterns/serialtask/SerialTask.java:39

(String[] args)

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

(String[] args)

src/main/java/com/example/concurrency/patterns/conditionqueues/ConditionQueue.java:65

(String[] args)

src/main/java/com/example/concurrency/patterns/producerconsumer/ProducerConsumer.java:43

MethodnonFairSemaphore

返回默认的非公平信号量，先请求的线程不一定先拿到信号量

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

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

MethodqueuableCachedPool

@see QueueAbleCachedThreadPoolBuilder

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

MethodrateLimiter

返回令牌桶算法的RateLimiter默认版，默认令牌桶大小等于期望的QPS，且刚启动时桶为空。 @permitsPerSecond 每秒允许的请求数，可看成QPS，同时将QPS平滑到毫秒级别上，请求到达速度不平滑时依赖缓冲能力.

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

MethodreadObject

(ObjectInputStream s)

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

MethodremoveFromLogger

将此appender从logger中移除.

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

MethodremoveFromRootLogger

将此appender从root logger中移除.

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

Resets variables maintaining the sum to zero. This method may be a useful alternative to creating a new adder, but is only effective if there are no

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

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

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

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

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

src/main/java/com/example/concurrency/features/threadstate/ThreadState.java:28

src/main/java/com/example/concurrency/features/threadstate/ThreadState.java:38

src/main/java/com/example/concurrency/features/threadstate/ThreadState.java:54

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

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

MethodsafeRunnable

防止用户没有捕捉异常导致中断了线程池中的线程, 使得SchedulerService无法继续执行. 在无法控制第三方包的Runnable实现时，调用本函数进行包裹.

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

返回采样器. @param selectPercent 采样率，在0-100 之间，可以有小数位

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

MethodscheduledPool

@see ScheduledThreadPoolBuilder

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

判断当前请求是否命中采样

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

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

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

修饰静态方法锁对象为当前类的Class对象 Class X

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

MethodsetAnotherValue

(String anotherValue)

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

MethodsetDaemon

与threadFactory互斥, 优先使用ThreadFactory 默认为NULL，不进行设置，使用JDK的默认值.

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

MethodsetDaemon

与threadFactory互斥, 优先使用ThreadFactory 默认为NULL，不进行设置，使用JDK的默认值.

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

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

MethodsetKeepAliveSecs

JDK默认值60秒太高，如高达1000线程时，要低于16QPS时才会开始回收线程, 因此改为默认10秒.

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

MethodsetKeepAliveSecs

(int keepAliveSecs)

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

MethodsetMaxSize

Max默认Integer.MAX_VALUE的，建议设置

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

MethodsetMaxSize

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

MethodsetMaxStackLevel

打印StackTrace的最大深度, 默认为8 @param maxStackLevel level

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

MethodsetMinSize

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

MethodsetMinSize

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

MethodsetPoolSize

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

MethodsetQueueSize

不设置时默认为-1, 使用无限长的LinkedBlockingQueue. 为正数时使用ArrayBlockingQueue.

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

MethodsetQueueSize

LinkedQueue长度, 默认100

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

MethodsetRejectHanlder

(RejectedExecutionHandler rejectHandler)

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

MethodsetRejectHanlder

(RejectedExecutionHandler rejectHandler)

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

MethodsetRejectHanlder

(RejectedExecutionHandler rejectHandler)

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

MethodsetThreadFactory

与threadNamePrefix互斥, 优先使用ThreadFactory

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

MethodsetThreadFactory

与threadNamePrefix互斥, 优先使用ThreadFactory

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

MethodsetThreadFactory

与threadNamePrefix互斥, 优先使用ThreadFactory

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

MethodsetThreadFactory

与threadNamePrefix互斥, 优先使用ThreadFactory

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

MethodsetThreadNamePrefix

与threadFactory互斥, 优先使用ThreadFactory

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

MethodsetThreadNamePrefix

(String threadNamePrefix)

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

MethodsetThreadNamePrefix

与threadFactory互斥, 优先使用ThreadFactory

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

MethodstopThread

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

MethodsumThenReset

Equivalent in effect to {@link #sum} followed by {@link #reset}. This method may apply for example during quiescent points between multithreaded compu

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

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

MethodtimeIntervalLimiter

返回时间间隔限制器. @param interval 间隔时间 @param timeUnit 间隔时间单位

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

(Account target, int amt)

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

(WaitAndNotifyAccount target, int amt)

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

转账 @param target 目标账户 @param amt 转账数量

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

(SafeAccount target, int amt)

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

(Account target, int amt)

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

MethodupdatePassword

更改密码 @param pw password

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

取款 @param amt amount

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

MethodwriteObject

(ObjectOutputStream s)

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

← previous201–277 of 277, ranked by callers