Functions — github.com/DQinYuan/javahighconcurrent

hub / github.com/DQinYuan/javahighconcurrent / functions

Functions225 in github.com/DQinYuan/javahighconcurrent

⨍ Functions 225◇ Types & classes 131

↓ 58 callersMethodget

()

src/main/java/javahighconcurrent/ch5/disruptor/producer_consumer/PCData.java:11

↓ 42 callersMethodcreate

(int id, String name)

src/main/java/javahighconcurrent/ch6/methodref/ConstrMethodRef.java:9

↓ 17 callersMethodstart

()

src/main/java/javahighconcurrent/ch5/network/aio/AIOEchoServer.java:22

↓ 12 callersMethodset

(long value)

src/main/java/javahighconcurrent/ch5/disruptor/producer_consumer/PCData.java:7

↓ 12 callersMethodtoString

()

src/main/java/javahighconcurrent/ch7_akka/PSO/PBestMsg.java:17

↓ 9 callersMethodexecute

(Runnable task)

src/main/java/javahighconcurrent/ch3/threadpool/disappear_error/TraceThreadPoolExecutor.java:13

↓ 6 callersMethodgetInstance

()

src/main/java/javahighconcurrent/ch5/singleton/StaticSingleton.java:16

↓ 6 callersMethodgetName

()

src/main/java/javahighconcurrent/ch6/methodref/User.java:20

↓ 6 callersMethodsubmit

(Runnable task)

src/main/java/javahighconcurrent/ch3/threadpool/disappear_error/TraceThreadPoolExecutor.java:18

↓ 4 callersMethodcalc

(int para)

src/main/java/javahighconcurrent/ch6/compeletablefuture/ComposeTest.java:12

↓ 4 callersMethoddisconnect

(SelectionKey sk)

src/main/java/javahighconcurrent/ch5/network/nio/MultiThreadNIOEchoServer.java:153

↓ 3 callersMethodequals

(Object obj)

src/main/java/javahighconcurrent/ch6/introduction/FunctionalInterfaceDemo.java:16

↓ 3 callersMethodgetId

()

src/main/java/javahighconcurrent/ch6/methodref/User.java:12

↓ 3 callersMethodwrap

(final Runnable task, final Exception clientStack, String clientThreadName)

src/main/java/javahighconcurrent/ch3/threadpool/disappear_error/TraceThreadPoolExecutor.java:27

↓ 2 callersMethodclientTrace

()

src/main/java/javahighconcurrent/ch3/threadpool/disappear_error/TraceThreadPoolExecutor.java:23

↓ 2 callersMethodfitness

将xp[1..4]换算成value @param x @return

src/main/java/javahighconcurrent/ch7_akka/PSO/Fitness.java:11

↓ 2 callersMethodgetValue

()

src/main/java/javahighconcurrent/ch7_akka/PSO/PBestMsg.java:13

↓ 2 callersMethodgetX

()

src/main/java/javahighconcurrent/ch7_akka/PSO/PsoValue.java:27

↓ 2 callersMethodrun

()

src/main/java/javahighconcurrent/ch6/introduction/DefaultMethodTest.java:18

↓ 2 callersMethodsetExchFlag

(int v)

src/main/java/javahighconcurrent/ch5/concurrent_sort/OddEvenSort.java:23

↓ 1 callersMethodapply

(Integer parameter)

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo7/AgentDemo.java:31

↓ 1 callersMethodbreath

()

src/main/java/javahighconcurrent/ch6/introduction/DefaultMethodTest.java:24

↓ 1 callersMethodcalc

(Integer pare)

src/main/java/javahighconcurrent/ch6/compeletablefuture/AsyncRunTest.java:22

↓ 1 callersMethodcalc

(int para)

src/main/java/javahighconcurrent/ch6/compeletablefuture/StreamAPI.java:8

↓ 1 callersMethodcustomStrategy

(ActorSystem system)

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo3/SupervisorMain.java:11

↓ 1 callersMethoddivZero

(int para)

src/main/java/javahighconcurrent/ch6/compeletablefuture/StreamAPI.java:18

↓ 1 callersMethoddoAccept

Accept a new client and set it up for reading.

src/main/java/javahighconcurrent/ch5/network/nio/MultiThreadNIOEchoServer.java:66

↓ 1 callersMethoddoRead

Read from a client. Enqueue the data on the clients output queue and set the selector to notify on OP_WRITE.

src/main/java/javahighconcurrent/ch5/network/nio/MultiThreadNIOEchoServer.java:95

↓ 1 callersMethoddoWork

()

src/main/java/javahighconcurrent/ch3/CyclicBarrierDemo.java:35

↓ 1 callersMethoddoWrite

Called when a SelectionKey is ready for writing.

src/main/java/javahighconcurrent/ch5/network/nio/MultiThreadNIOEchoServer.java:122

↓ 1 callersMethodenqueue

(ByteBuffer bb)

src/main/java/javahighconcurrent/ch5/network/nio/MultiThreadNIOEchoServer.java:37

↓ 1 callersMethodgetCount

()

src/main/java/javahighconcurrent/ch6/longadder/LongAdderDemo.java:33

↓ 1 callersMethodgetExchFlag

()

src/main/java/javahighconcurrent/ch5/concurrent_sort/OddEvenSort.java:27

↓ 1 callersMethodgetOutputQueue

()

src/main/java/javahighconcurrent/ch5/network/nio/MultiThreadNIOEchoServer.java:32

↓ 1 callersMethodgetResult

()

src/main/java/javahighconcurrent/ch5/future_model/myfuture/Data.java:4

↓ 1 callersMethodgetUnsafeInstance

()

src/main/java/javahighconcurrent/ch4/unsafe/UnSafeFactory.java:8

↓ 1 callersMethodinc

()

src/main/java/javahighconcurrent/ch6/longadder/LongAdderDemo.java:29

↓ 1 callersMethodonComplete

(Throwable throwable, Iterable<Integer> integers)

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo7/AgentDemo.java:90

↓ 1 callersMethodpOddEventSort

(int[] arr)

src/main/java/javahighconcurrent/ch5/concurrent_sort/OddEvenSort.java:54

↓ 1 callersMethodpushData

(ByteBuffer bb)

src/main/java/javahighconcurrent/ch5/disruptor/producer_consumer/Producer.java:14

↓ 1 callersMethodrequest

(final String queryStr)

src/main/java/javahighconcurrent/ch5/future_model/myfuture/Client.java:5

↓ 1 callersMethodrun

为了解决多继承中的父类方法重名问题这里指定继承自IHorse

src/main/java/javahighconcurrent/ch6/introduction/DefaultMethodTest.java:47

↓ 1 callersMethodrunTest

()

src/main/java/javahighconcurrent/ch6/longadder/FalseSharingElegant.java:28

↓ 1 callersMethodrunTest

()

src/main/java/javahighconcurrent/ch5/disruptor/falseshare/testfalseshare/FalseSharing.java:36

↓ 1 callersMethodsetReady

(boolean re)

src/main/java/javahighconcurrent/ch2/NoVisibility.java:8

↓ 1 callersMethodsetRealData

(RealData realData)

src/main/java/javahighconcurrent/ch5/future_model/myfuture/FutureData.java:8

↓ 1 callersMethodstartServer

()

src/main/java/javahighconcurrent/ch5/network/nio/MultiThreadNIOEchoServer.java:168

↓ 1 callersMethodtestAtomic

()

src/main/java/javahighconcurrent/ch6/longadder/LongAdderDemo.java:85

↓ 1 callersMethodtestAtomicLong

()

src/main/java/javahighconcurrent/ch6/longadder/LongAdderDemo.java:116

↓ 1 callersMethodtestSync

()

src/main/java/javahighconcurrent/ch6/longadder/LongAdderDemo.java:57

↓ 1 callersMethodupdateVelocity

(int i)

src/main/java/javahighconcurrent/ch7_akka/PSO/Bird.java:90

↓ 1 callersMethodupdateX

(int i)

src/main/java/javahighconcurrent/ch7_akka/PSO/Bird.java:100

↓ 1 callersMethodvalidateX

()

src/main/java/javahighconcurrent/ch7_akka/PSO/Bird.java:106

MethodAIOEchoServer

()

src/main/java/javahighconcurrent/ch5/network/aio/AIOEchoServer.java:18

MethodAccepter

(ActorRef tcpManager)

src/main/java/javahighconcurrent/ch7_akka/EchoServer/Accepter.java:17

MethodAskThread

(CompletableFuture<Integer> re)

src/main/java/javahighconcurrent/ch6/compeletablefuture/AskThread.java:12

MethodAtomicThread

(long starttime)

src/main/java/javahighconcurrent/ch6/longadder/LongAdderDemo.java:70

MethodBarrierRun

(boolean flag, int n)

src/main/java/javahighconcurrent/ch3/CyclicBarrierDemo.java:51

MethodDivTask

(int a, int b)

src/main/java/javahighconcurrent/ch3/threadpool/disappear_error/DivTask.java:7

MethodEchoClient

()

src/main/java/javahighconcurrent/ch5/network/nio/MultiThreadNIOEchoServer.java:27

MethodFalseSharing

(int arrayIndex)

src/main/java/javahighconcurrent/ch5/disruptor/falseshare/testfalseshare/FalseSharing.java:26

MethodFalseSharingElegant

(int arrayIndex)

src/main/java/javahighconcurrent/ch6/longadder/FalseSharingElegant.java:18

MethodGBestMsg

(PsoValue value)

src/main/java/javahighconcurrent/ch7_akka/PSO/GBestMsg.java:9

MethodHandleMsg

(SelectionKey sk,ByteBuffer bb)

src/main/java/javahighconcurrent/ch5/network/nio/MultiThreadNIOEchoServer.java:45

MethodHandleMsg

(Socket clientSocket)

src/main/java/javahighconcurrent/ch5/network/bio/MultiThreadEchoServer.java:18

MethodImmutableMessage

(int sequenceNumber, List<String> values)

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo1/ImmutableMessage.java:15

MethodLongAddrThread

(long starttime)

src/main/java/javahighconcurrent/ch6/longadder/LongAdderDemo.java:99

MethodMatrixMulTask

(Matrix m1, Matrix m2, String pos)

src/main/java/javahighconcurrent/ch5/matrix_multiply/MatrixMulTask.java:17

MethodOddEvenSortTask

(int i, CountDownLatch latch, int[] arr)

src/main/java/javahighconcurrent/ch5/concurrent_sort/OddEvenSort.java:36

MethodPBestMsg

(PsoValue value)

src/main/java/javahighconcurrent/ch7_akka/PSO/PBestMsg.java:9

MethodParseDate

(int i)

src/main/java/javahighconcurrent/ch4/ThreadLocalDemo_gc.java:34

MethodPerson

(int age, String name, Country country)

src/test/java/javahighconcurrent/personstream/Person.java:13

MethodProducer

(RingBuffer<PCData> ringBuffer)

src/main/java/javahighconcurrent/ch5/disruptor/producer_consumer/Producer.java:10

MethodPsoValue

(double value, List<Double> x)

src/main/java/javahighconcurrent/ch7_akka/PSO/PsoValue.java:16

MethodRealData

(String para)

src/main/java/javahighconcurrent/ch5/future_model/myfuture/RealData.java:6

MethodRealData

(String para)

src/main/java/javahighconcurrent/ch5/future_model/jdkfuture/RealData.java:9

MethodSoldier

(CyclicBarrier cyclic, String soldier)

src/main/java/javahighconcurrent/ch3/CyclicBarrierDemo.java:15

MethodStaticSingleton

()

src/main/java/javahighconcurrent/ch5/singleton/StaticSingleton.java:8

MethodStudent

(int score)

src/main/java/javahighconcurrent/ch6/parallelstream/Student.java:12

MethodSyncThread

(LongAdderDemo o,long starttime)

src/main/java/javahighconcurrent/ch6/longadder/LongAdderDemo.java:41

MethodTraceThreadPoolExecutor

(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)

src/main/java/javahighconcurrent/ch3/threadpool/disappear_error/TraceThreadPoolExecutor.java:9

MethodUser

(int id, String name)

src/main/java/javahighconcurrent/ch6/methodref/User.java:7

MethodWatchActor

(ActorRef ref)

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo2/WatchActor.java:14

Methodapply

(Throwable t)

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo3/Supervisor.java:20

Methodapply

(Object message)

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo5/BabyActor.java:18

Methodcall

()

src/main/java/javahighconcurrent/ch5/future_model/jdkfuture/RealData.java:13

Methodcompleted

(Void result, Object attachment)

src/main/java/javahighconcurrent/ch5/network/aio/AIOClient.java:15

Methodcompleted

(AsynchronousSocketChannel result, Object attachment)

src/main/java/javahighconcurrent/ch5/network/aio/AIOEchoServer.java:30

Methodcompute

()

src/main/java/javahighconcurrent/ch5/matrix_multiply/MatrixMulTask.java:23

MethoddistanceFromOrigin

()

src/main/java/javahighconcurrent/ch6/stampedlock/Point.java:23

Methodeat

()

src/main/java/javahighconcurrent/ch6/introduction/DefaultMethodTest.java:16

Methodeat

()

src/main/java/javahighconcurrent/ch6/introduction/DefaultMethodTest.java:30

Methodeat

()

src/main/java/javahighconcurrent/ch6/introduction/DefaultMethodTest.java:38

Methodequals

(Object obj)

src/main/java/javahighconcurrent/ch6/introduction/FunctionalInterfaceDemo.java:26

Methodfailed

(Throwable exc, ByteBuffer attachment)

src/main/java/javahighconcurrent/ch5/network/aio/AIOClient.java:35

Methodfailed

(Throwable exc, Object attachment)

src/main/java/javahighconcurrent/ch5/network/aio/AIOEchoServer.java:59

Methodfinalize

()

src/main/java/javahighconcurrent/ch4/ThreadLocalDemo_gc.java:21

Methodfinalize

()

src/main/java/javahighconcurrent/ch4/ThreadLocalDemo_gc.java:43

MethodgetResult

()

src/main/java/javahighconcurrent/ch5/future_model/myfuture/RealData.java:19

MethodgetResult

()

src/main/java/javahighconcurrent/ch5/future_model/myfuture/FutureData.java:17

next →1–100 of 225, ranked by callers