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

Methodqueue

()

src/main/java/com/javaedge/concurrency/mq/rabbitmq/RabbitMqConfig.java:14

Methodreceive

(ConsumerRecord<?, ?> record)

src/main/java/com/javaedge/concurrency/mq/kafka/KafkaReceiver.java:16

Methodreceive

(String message)

src/main/java/com/javaedge/concurrency/mq/rabbitmq/RabbitMqServer.java:15

MethodrejectedExecution

(Runnable r, ThreadPoolExecutor executor)

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

Methodrun

()

src/main/java/Balking/Q5/TestThread.java:4

Methodrun

()

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

Methodrun

()

src/main/java/com/javaedge/concurrency/LockSupportTest.java:12

Methodrun

()

src/main/java/com/javaedge/concurrency/syncContainer/VectorExample2.java:21

Methodrun

()

src/main/java/com/javaedge/concurrency/deadLock/DeadLock.java:26

Methodrun

()

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

Methodrun

()

src/main/java/com/javaedge/concurrency/threadLocal/DirtyDataInThreadLocal.java:26

Methodrun

()

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

Methodrun

()

src/main/java/com/javaedge/concurrency/threadpool/ThreadPoolExample4.java:36

Methodrun

()

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

Methodrun

()

src/main/java/com/javaedge/concurrency/common/volatiletest/VisibilityDemo2.java:27

Methodrun

()

src/main/java/com/javaedge/concurrency/common/volatiletest/VisibilityDemo1.java:18

Methodrun

()

src/main/java/com/javaedge/concurrency/common/volatiletest/VisibilityDemo.java:31

Methodrun

()

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

Methodrun

()

src/main/java/workerthread/v2/Channel.java:14

Methodrun

()

src/main/java/workerthread/v1/WorkerThread.java:17

Methodrun

()

src/main/java/workerthread/v1/ClientThread.java:20

Methodsend

(@RequestParam("message") String message)

src/main/java/com/javaedge/concurrency/mq/MqController.java:26

Methodsend

(String msg)

src/main/java/com/javaedge/concurrency/mq/kafka/KafkaSender.java:24

Methodsend

(String message)

src/main/java/com/javaedge/concurrency/mq/rabbitmq/RabbitMqClient.java:20

Methodset

(@RequestParam("k") String k, @RequestParam("v") String v)

src/main/java/com/javaedge/concurrency/cache/CacheController.java:19

MethodstartWorkers

()

src/main/java/workerthread/v2/Channel.java:9

MethodsuspendResumeDeadLockTest

死锁的suspend/resume suspend并不会像wait一样释放锁，容易写出死锁代码

src/main/java/com/javaedge/concurrency/common/communication/ThreadCommunication.java:47

MethodsuspendResumeDeadLockTest2

导致程序永久挂起的suspend/resume

src/main/java/com/javaedge/concurrency/common/communication/ThreadCommunication.java:75

MethodsuspendResumeTest

正常的suspend/resume

src/main/java/com/javaedge/concurrency/common/communication/ThreadCommunication.java:24

Methodtest

()

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

Methodtest

()

src/main/java/com/javaedge/concurrency/TestController.java:12

Methodtest

(final int a)

src/main/java/com/javaedge/concurrency/immutable/ImmutableExample1.java:31

Methodtest

()

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

Methodtest1

()

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

Methodtest1

修饰一个代码块 @param j

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

Methodtest2

(Vector<Integer> v1)

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

Methodtest2

()

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

Methodtest2

(Object arg)

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

Methodtest2

(int j)

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

Methodtest3

(Vector<Integer> v1)

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

Methodtest3

()

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

Methodtest3

(Object arg)

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

MethodthreadLocalTest

()

src/main/java/com/javaedge/concurrency/common/closure/ThreadClosure.java:18

MethodthreadPoolExecutorTest1

()

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

MethodthreadPoolExecutorTest2

()

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

MethodthreadPoolExecutorTest3

3、线程池信息：核心线程数量5，最大数量5，无界队列，超出核心线程数量的线程存活时间：5秒 @throws Exception

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

MethodthreadPoolExecutorTest4

4、线程池信息：核心线程数量0，最大数量Integer.MAX_VALUE，SynchronousQueue队列，超出核心线程数量的线程存活时间：60秒 @throws Exception

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

MethodthreadPoolExecutorTest5

5、定时执行线程池信息：3秒后执行，一次性任务，到点就执行 <br/> 核心线程数量5，最大数量Integer.MAX_VALUE，DelayedWorkQueue延时队列，超出核心线程数量的线程存活时间：0秒 @throws Exception

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

MethodthreadPoolExecutorTest6

6、定时执行线程池信息：线程固定数量5 ，<br/> 核心线程数量5，最大数量Integer.MAX_VALUE，DelayedWorkQueue延时队列，超出核心线程数量的线程存活时间：0秒 @throws Exception

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

MethodthreadPoolExecutorTest7

7、终止线程：线程池信息：核心线程数量5，最大数量10，队列大小3，超出核心线程数量的线程存活时间：5秒，指定拒绝策略的 @throws Exception

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

MethodthreadPoolExecutorTest8

8、立刻终止线程：线程池信息：核心线程数量5，最大数量10，队列大小3，超出核心线程数量的线程存活时间：5秒，指定拒绝策略的 @throws Exception

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

MethodtoString

()

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

MethodtryRelease

(int ignore)

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

Methodunlock

解锁

src/main/java/com/javaedge/concurrency/aqs/SampleLock.java:21

Methodup

()

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

MethodwaitNotifyDeadLockTest

会导致程序永久等待的wait/notify

src/main/java/com/javaedge/concurrency/common/communication/ThreadCommunication.java:133

MethodwaitNotifyTest

正常的wait/notify

src/main/java/com/javaedge/concurrency/common/communication/ThreadCommunication.java:103

Methodwarm

(Food food)

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

Methodwork

(Machina m)

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

← previous301–359 of 359, ranked by callers