[DISCUSS] FLINK-19089: improvement of ClosableBlockingQueue

2020-09-05 Thread dugenkui
hi, community: The implements of closable blocking queue[1]  use a fair lock ReentrantLock to guarantee thread-safe. The changes below may be help: 1. replace ReentrantLock with ReentrantReadWriteLock to improve concurrency: in fair mode, the ReentrantReadWriteLock has better performance than

[jira] [Created] (FLINK-19089) Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue

2020-08-28 Thread dugenkui (Jira)
dugenkui created FLINK-19089: Summary: Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue Key: FLINK-19089 URL: https://issues.apache.org/jira/browse/FLINK-19089 Project: Flink