fix race condition of MessageRecvBuffers (#162)
authorJermy Li <javaloveme@gmail.com>
Mon, 13 Dec 2021 06:15:39 +0000 (14:15 +0800)
committerGitHub <noreply@github.com>
Mon, 13 Dec 2021 06:15:39 +0000 (14:15 +0800)
commitd93bc3170c4be1f7188d2e82afc5532753dd0825
tree7ee1edb0748e61b88712612d200f3855bfcedc51
parent875bf7fb5a273316c52a860f90016679a20d79c9
fix race condition of MessageRecvBuffers (#162)

* fix race condition of MessageRecvBuffers

* Separate sort-start event and sort-end event
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvBuffers.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvPartition.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvBuffersTest.java