MCPcopy Create free account

hub / github.com/DreamOfTheRedChamber/system-design-interviews / functions

Functions297 in github.com/DreamOfTheRedChamber/system-design-interviews

⨍ Functions 297◇ Types & classes 125
↓ 1 callersMethodstart
()
code/multithreads/basics/conditionVariable/ConditionVariableWithReentrantLock.java:18
↓ 1 callersMethodstartServer
服务端启动RPC框架，监听接口，开始提供远程服务。 @return 服务实例，用于程序停止的时候安全关闭服务。
code/simple-rpc-framework-master/rpc-api/src/main/java/com/github/liyue2008/rpc/RpcAccessPoint.java:66
↓ 1 callersMethodsyn
()
code/multithreads/ThreadMethods/SleepDoesNotReleaseMonitor.java:22
↓ 1 callersMethodthrowInMethod
()
code/multithreads/StopThreads/Behaviors/DeclareInterruptExceptionToForceHandling.java:25
MethodCode
(int code, String message)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Code.java:39
MethodCommand
(Header header, byte [] payload)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Command.java:24
MethodConsumer
( EventStorage storage)
code/multithreads/ObjectMethods/ProducerConsumerWithWaitNotify.java:43
MethodConsumer
(BlockingQueue storage)
code/multithreads/StopThreads/WrongWays/InterruptedAlwaysSucceed.java:64
MethodConsumer
(BlockingQueue storage)
code/multithreads/StopThreads/WrongWays/VolatileUnluckyCase.java:71
MethodEmptyingWorker
(Exchanger<List<Integer>> exchanger )
code/multithreads/basics/concurrencyLibrary/Exchangers.java:68
MethodEventStorage
()
code/multithreads/ObjectMethods/ProducerConsumerWithWaitNotify.java:61
MethodFillingWorker
(Exchanger<List<Integer>> exchanger )
code/multithreads/basics/concurrencyLibrary/Exchangers.java:21
MethodFirstWorker
(BlockingQueue<String> blockingQueue )
code/multithreads/basics/concurrencyLibrary/BlockingQueues.java:24
MethodFirstWorker2
(BlockingQueue<String> blockingQueue )
code/multithreads/basics/concurrencyLibrary/PriorityBlockingQueues.java:25
MethodFirstWorker3
(ConcurrentMap<String, Integer> map)
code/multithreads/basics/concurrencyLibrary/ConcurrentMaps.java:10
MethodHeader
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Header.java:25
MethodInFlightRequests
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/InFlightRequests.java:36
MethodNettyClient
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyClient.java:48
MethodNettyTransport
(Channel channel, InFlightRequests inFlightRequests)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyTransport.java:33
MethodProcessor
(int id )
code/multithreads/Future/CallableReturn.java:15
MethodProducer
( EventStorage storage)
code/multithreads/ObjectMethods/ProducerConsumerWithWaitNotify.java:26
MethodProducer
(BlockingQueue storage)
code/multithreads/StopThreads/WrongWays/InterruptedAlwaysSucceed.java:37
MethodProducer
(BlockingQueue storage)
code/multithreads/StopThreads/WrongWays/VolatileUnluckyCase.java:41
MethodRequestHandlerRegistry
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/RequestHandlerRegistry.java:39
MethodRequestInvocation
(RequestHandlerRegistry requestHandlerRegistry)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/RequestInvocation.java:36
MethodResponseFuture
(int requestId, CompletableFuture<Command> future)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/ResponseFuture.java:29
MethodResponseHeader
(int type, int version, int requestId, Throwable throwable)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/ResponseHeader.java:26
MethodResponseInvocation
(InFlightRequests inFlightRequests)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/ResponseInvocation.java:35
MethodRpcRequest
(String interfaceName, String methodName, byte[] serializedArguments)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/client/stubs/RpcRequest.java:25
MethodSecondWorker
(BlockingQueue<String> blockingQueue )
code/multithreads/basics/concurrencyLibrary/BlockingQueues.java:52
MethodSecondWorker2
(BlockingQueue<String> blockingQueue )
code/multithreads/basics/concurrencyLibrary/PriorityBlockingQueues.java:55
MethodSecondWorker3
(ConcurrentMap<String, Integer> map)
code/multithreads/basics/concurrencyLibrary/ConcurrentMaps.java:34
MethodSerializeException
(String msg)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/SerializeException.java:21
MethodWorker
(String name )
code/multithreads/basics/yieldThread/ThreadPriority.java:36
MethodWorker
(int id, CountDownLatch latch )
code/multithreads/basics/concurrencyLibrary/CountDownLatches.java:33
MethodWorker2
(int id, CyclicBarrier cyclicBarrier )
code/multithreads/basics/concurrencyLibrary/CyclicBarriers.java:42
MethodaddServiceProvider
(T service, Class<T> serviceClass)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/NettyRpcAccessPoint.java:62
MethodaddServiceProvider
(Class<? extends T> serviceClass, T serviceProvider)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/server/RpcRequestHandler.java:72
Methodcall
()
code/multithreads/Future/CallableReturn.java:20
MethodchannelRead0
(ChannelHandlerContext channelHandlerContext, Command request)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/RequestInvocation.java:40
MethodchannelRead0
(ChannelHandlerContext channelHandlerContext, Command response)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/ResponseInvocation.java:39
Methodclose
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/NettyRpcAccessPoint.java:82
Methodclose
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/InFlightRequests.java:67
Methodclose
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyClient.java:111
Methodconnect
(URI nameServiceUri)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/nameservice/LocalFileNameService.java:48
MethodcreateStub
(Transport transport, Class<T> serviceClass)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/client/DynamicStubFactory.java:46
MethodcreateTransport
(URI uri)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/NettyRpcAccessPoint.java:54
MethodcreateTransport
(SocketAddress address, long connectionTimeout)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyClient.java:61
Methoddecode
(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/CommandDecoder.java:30
MethoddecodeHeader
(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/RequestDecoder.java:26
MethoddecodeHeader
(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/ResponseDecoder.java:31
Methodencode
(ChannelHandlerContext channelHandlerContext, Object o, ByteBuf byteBuf)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/CommandEncoder.java:28
MethodencodeHeader
(ChannelHandlerContext channelHandlerContext, Header header, ByteBuf byteBuf)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/ResponseEncoder.java:29
MethodencodeHeader
(ChannelHandlerContext channelHandlerContext, Header header, ByteBuf byteBuf)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/RequestEncoder.java:25
MethodentrySize
(Map.Entry<String, List<URI>> e)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/impl/MetadataSerializer.java:75
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/RequestInvocation.java:60
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/ResponseInvocation.java:49
Methodfoobar
()
code/multithreads/basics/mutex/SynchronizedObjectsClassLevel.java:52
Methodfoobar
()
code/multithreads/basics/mutex/SynchronizedObjectsInstanceLevel.java:38
MethodgetRemoteService
(URI uri, Class<T> serviceClass)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/NettyRpcAccessPoint.java:48
MethodgetRequestId
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/ResponseFuture.java:35
MethodgetSerializeClass
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/impl/MetadataSerializer.java:119
MethodgetSerializeClass
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/impl/RpcRequestSerializer.java:76
MethodgetSerializeClass
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/impl/StringSerializer.java:46
Methodhandle
(Command requestCommand)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/server/RpcRequestHandler.java:41
Methodhello
(String name)
code/simple-rpc-framework-master/server/src/main/java/com/github/liyue2008/rpc/server/HelloServiceImpl.java:26
MethodinitChannel
(Channel channel)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyClient.java:92
MethodinitChannel
(Channel channel)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyServer.java:90
MethodinvokeRemote
(RpcRequest request)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/client/stubs/AbstractStub.java:35
Methodlength
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/ResponseHeader.java:42
MethodlookupService
(String serviceName)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/nameservice/LocalFileNameService.java:95
Methodmain
(String[] args)
code/multithreads/Future/CallableReturn.java:31
Methodmain
(String[] args)
code/multithreads/ObjectMethods/WaitNotifyAll.java:12
Methodmain
(String[] args)
code/multithreads/ObjectMethods/WaitAndNotify.java:42
Methodmain
(String[] args)
code/multithreads/ObjectMethods/WaitOnlyReleasesItsOwnMonitor.java:18
Methodmain
(String[] args)
code/multithreads/ObjectMethods/ProducerConsumerWithWaitNotify.java:13
Methodmain
(String[] args)
code/multithreads/StopThreads/BestPractices/BlockingCase_CatchInterruptException.java:8
Methodmain
(String[] args)
code/multithreads/StopThreads/BestPractices/NoBlockingCase_CheckInterruptFlag.java:21
Methodmain
(String[] args)
code/multithreads/StopThreads/BestPractices/BlockingCase_CheckInterruptFlag.java:9
Methodmain
(String[] args)
code/multithreads/StopThreads/WrongWays/InterruptedAlwaysSucceed.java:12
Methodmain
(String[] args)
code/multithreads/StopThreads/WrongWays/VolatileLuckyCase.java:27
Methodmain
(String[] args)
code/multithreads/StopThreads/WrongWays/VolatileUnluckyCase.java:13
Methodmain
(String[] args)
code/multithreads/StopThreads/Behaviors/InterruptFlagBeingClearedbyTryCatch.java:10
Methodmain
(String[] args)
code/multithreads/StopThreads/Behaviors/RestoreInterruptFlagBeingClearedbyTryCatch.java:30
Methodmain
(String[] args)
code/multithreads/StopThreads/Behaviors/DeclareInterruptExceptionToForceHandling.java:29
Methodmain
( String[] args )
code/multithreads/basics/volatileKeyword/StopThread.java:13
Methodmain
( String[] args )
code/multithreads/basics/volatileKeyword/MultipleWriters.java:19
Methodmain
(String[] args)
code/multithreads/basics/semaphore/DownloadRateLimiter.java:56
Methodmain
( String[] args )
code/multithreads/basics/mutex/SynchronizedObjectsClassLevel.java:57
Methodmain
( String[] args )
code/multithreads/basics/mutex/SynchronizedClassObjectClassLevel.java:39
Methodmain
( String[] args )
code/multithreads/basics/mutex/SynchronizedMethods.java:47
Methodmain
( String[] args )
code/multithreads/basics/mutex/SynchronizedReentrant.java:30
Methodmain
( String[] args )
code/multithreads/basics/mutex/SynchronizedCodeBlocks.java:26
Methodmain
( String[] args )
code/multithreads/basics/mutex/SynchronizedObjectsInstanceLevel.java:43
Methodmain
(String[] args)
code/multithreads/basics/joinThread/WaitForThreadToFinish.java:52
Methodmain
(String[] args)
code/multithreads/basics/yieldThread/ThreadPriority.java:60
Methodmain
(String[] args)
code/multithreads/basics/reentrantlock/ReentrantLockProducerConsumer.java:40
Methodmain
(String[] args)
code/multithreads/basics/reentrantlock/ReentrantLockHelloWorld.java:53
Methodmain
( String[] args )
code/multithreads/basics/conditionVariable/ConditionVariableWithSynchronizedKeyWord.java:58
Methodmain
(String[] args)
code/multithreads/basics/conditionVariable/WaitNotifyHelloWorld.java:28
← previousnext →101–200 of 297, ranked by callers