Fix send thread may blocked all the time (#61)
authorLinary <liningrui@baidu.com>
Mon, 21 Jun 2021 06:22:46 +0000 (14:22 +0800)
committerGitHub <noreply@github.com>
Mon, 21 Jun 2021 06:22:46 +0000 (14:22 +0800)
commitea4c7434b5236533a755e2452fb010e65201eb8a
tree32c20fb8d5c3464660c6ae77cfd68312bf855b0d
parent435d31af301e0613b54a36a2d1a198adc90325dc
Fix send thread may blocked all the time (#61)

* Fix send thread may blocked all the time
* Add back MultiQueue class
16 files changed:
.github/workflows/ci.yml
computer-api/src/main/java/com/baidu/hugegraph/computer/core/io/GraphComputeInput.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/io/GraphComputeOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageQueue.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/QueuedMessage.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/QueuedMessageSender.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/ReceiverUtil.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageQueueTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/MultiQueueTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/QueuedMessageTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/SenderTestSuite.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/WriteBuffersTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerServiceTest.java