Types & classes — github.com/DQinYuan/javahighconcurrent

CodeHub MCPcopy Create free account

hub / github.com/DQinYuan/javahighconcurrent / types & classes

Types & classes131 in github.com/DQinYuan/javahighconcurrent

⨍ Functions 225◇ Types & classes 131

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

ClassAIOEchoServer

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

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

ClassActorBoxMain

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo4/ActorBoxMain.java:10

src/main/java/javahighconcurrent/ch8/UnsafeArrayList.java:9

Created by liubenlong on 2017/1/12.

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

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo6/AskMain.java:19

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

ClassAsyncRunTest

CompletableFuture.supplyAsync函数中的lambda会在一个新的线程中执行类似的工厂方法如下 supplyAsync(supplier) supplyAsync(supplier, executor) runAsync(runnable)

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

ClassAtomicThread

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

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

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo5/BabyMain.java:14

ClassBadMethodRef

src/main/java/javahighconcurrent/ch6/methodref/BadMethodRef.java:6

ClassBarrierRun

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

代表一个粒子

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

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

ClassCompanyActor

Created by 燃烧杯 on 2018/5/18.

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo8/CompanyActor.java:11

ClassComparatorTest

src/main/java/javahighconcurrent/ch6/introduction/ComparatorTest.java:8

ClassComposeTest

thenCompose方法用于接力两个CompletableFuture themCombine方法用于组合两个CompletableFuture的输出

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

ClassConstrMethodRef

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

消费者，由Disruptor封装成了响应式的形式

src/main/java/javahighconcurrent/ch5/disruptor/producer_consumer/Consumer.java:8

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

ClassCyclicBarrierDemo

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

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

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo2/DeadMain.java:10

ClassDefaultMethodTest

java默认方法的相关demo

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

src/main/java/javahighconcurrent/ch5/pipeline/Div.java:6

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

ClassEchoClient

src/main/java/javahighconcurrent/ch5/network/HeavySocketClient.java:18

ClassEchoClient

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

ClassEmployeeActor

Created by 燃烧杯 on 2018/5/18.

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo8/EmployeeActor.java:11

ClassFalseSharing

CPU cache line: CPU读取CPU cache的单位，主流CPU的Cache line是64B 本来不共享的数据出现在同一个CPU cache line中，会造成伪共享问题通过给数据填充padding是指达到CPU cache line大小能够避免这个问题以下优化在win10 j

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

ClassFalseSharingElegant

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

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

InterfaceFunctionalInterfaceDemo

函数式接口的定义：接口只有一个“抽象方法”，注意该方法不能已经被Object实现

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

ClassFutureData

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

ClassFutureMain

使用Callable实例构造一个FutureTask实例，然后交给线程池

src/main/java/javahighconcurrent/ch5/future_model/jdkfuture/FutureMain.java:8

代表全局最优

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

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo1/Greeter.java:5

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

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

src/main/java/javahighconcurrent/ch7_akka/EchoServer/Handler.java:9

ClassHeavySocketClient

src/main/java/javahighconcurrent/ch5/network/HeavySocketClient.java:15

ClassHelloMainSimpler

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo1/HelloMainSimpler.java:10

ClassHelloWorld

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo1/HelloWorld.java:7

ClassHoldCPUReadThread

src/main/java/javahighconcurrent/ch6/stampedlock/StampedLockCPUDemo.java:40

InterfaceIAnimal

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

InterfaceIDonkey

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

InterfaceIHorse

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

ClassImmutableMessage

Created by 燃烧杯 on 2018/5/18.

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

ClassInstanceMethodRef

方法引用是Java提出的用来简化lambda表达式的一种手段分为以下几种： 1.静态方法引用：ClassName::methodName 2.实例上的实例方法引用：instanceReference::methodName 3.超类上的实例方法引用：super::m

src/main/java/javahighconcurrent/ch6/methodref/InstanceMethodRef.java:19

ClassIntConsumerTest

通过addThen组装IntConsumer

src/main/java/javahighconcurrent/ch6/introduction/IntConsumerTest.java:9

InterfaceIntHandler

下面的接口是一个函数式接口

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

ClassIntroduction

函数式编程的特点： 1、函数作为一等公民 a.可以将函数作为参数传给另一个函数 b.函数可以作为另一个函数的返回值 2、无副作用副作用:指函数在调用过程中除了返回值外，还修改了函数外部的状态显式函数:与外界交互数据的唯一渠道就是参数和返回值隐式函数:会读

src/main/java/javahighconcurrent/ch6/introduction/Introduction.java:23

ClassLambdaTest

src/test/java/javahighconcurrent/LambdaTest.java:9

ClassLambdaTest

src/main/java/javahighconcurrent/ch6/introduction/LambdaTest.java:8

ClassLhsPadding

src/main/java/javahighconcurrent/ch5/disruptor/falseshare/mockdisruptot/Sequence.java:3

ClassLongAccumulatorTest

LongAccumulator是LongAdder的一个扩展允许自定义二元Long操作，构造函数的第一个参数就必须传入一个自定义的二元Long操作，返回一个Long

src/main/java/javahighconcurrent/ch6/longadder/LongAccumulatorTest.java:10

ClassLongAdderDemo

测试synchronized, atomic以及longadder的性能作者书上测试的结果是测试synchronized < atomic < longadder 但是在我电脑上测的结果longadder性能不如atomic 可能是因为我电脑核数太多导致竞争不是那么激烈？？

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

ClassLongAdderTest

src/test/java/javahighconcurrent/LongAdderTest.java:7

ClassLongAddrThread

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

src/main/java/javahighconcurrent/ch7_akka/EchoServer/Main.java:8

src/main/java/javahighconcurrent/ch5/singleton/Main.java:3

src/main/java/javahighconcurrent/ch5/future_model/myfuture/Main.java:3

src/main/java/javahighconcurrent/ch5/disruptor/producer_consumer/Main.java:12

ClassMasterBird

src/main/java/javahighconcurrent/ch7_akka/PSO/MasterBird.java:8

ClassMatrixMulTask

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

src/main/java/javahighconcurrent/ch5/pipeline/Msg.java:3

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo3/RestartActor.java:7

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

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo4/MyWorker.java:9

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo2/MyWorker.java:10

src/main/java/javahighconcurrent/ch7_akka/AkkaRouterDemo/MyWorker.java:9

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo1/Greeter.java:6

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

ClassMultiThreadEchoServer

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

ClassMultiThreadNIOEchoServer

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

src/main/java/javahighconcurrent/ch5/pipeline/Multiply.java:6

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

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo4/MyWorker.java:7

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo2/MyWorker.java:8

src/main/java/javahighconcurrent/ch7_akka/AkkaRouterDemo/MyWorker.java:7

ClassNoVisibility

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

InterfaceNonFunc

这不是一个函数式接口，因为equals已经被Object实现了

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

ClassOddEvenSort

奇偶交换排序，冒泡排序的一种并行化改进将排序分成两个阶段，奇交换和偶交换。奇交换：只比较奇数索引及其相邻后继元素偶交换：只比较偶数索引及其后继元素奇偶交换总是成对出现，这样才能保证比较涉及到数组中每一个元素通过这种方式解开了冒泡排序的数据相关性

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

ClassOddEvenSortTask

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

代表个体最优

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

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

ClassPCDataFactory

工厂类，会在Disruptor系统初始化时，构造所有的缓冲区中的对象实例

src/main/java/javahighconcurrent/ch5/disruptor/producer_consumer/PCDataFactory.java:8

ClassPMatrixMul

使用ForkJoinPool进行同步的一个案例

src/main/java/javahighconcurrent/ch5/matrix_multiply/PMatrixMul.java:14

src/main/java/javahighconcurrent/ch7_akka/PSO/PSOMain.java:7

ClassPStreamMain

使用流水线模式，能够将原本存在数据依赖的流程并行化

src/main/java/javahighconcurrent/ch5/pipeline/PStreamMain.java:6

ClassParallelArrayTest

src/main/java/javahighconcurrent/ch6/parallelstream/ParallelArrayTest.java:6

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

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

src/main/java/javahighconcurrent/ch5/pipeline/Plus.java:6

StampedLock通过引入乐观读改进了读写锁

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

并行求质数

src/main/java/javahighconcurrent/ch6/parallelstream/PrimeUtil.java:8

src/main/java/javahighconcurrent/ch7_akka/AkkaDemo6/Printer.java:9

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

next →1–100 of 131, ranked by callers