tree e0d054ba2365523085e896bb2aa554843c9d0458
parent 77cf09eafa4f1626a53a1fe2e65dd25f377c1127
author hangc0276 <hangc0276@163.com> 1617245140 +0800
committer GitHub <noreply@github.com> 1617245140 +0800
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJgZTPUCRBK7hj4Ov3rIwAAdHIIAJj8gttQNal6QOiregLdVMYy
 uUO+XQI2k7rvtSZ/2zHCn7FuX91yhDBMvftN88cZKHUevrulmPh0SeR7v6JIfi7C
 Z1bllHxZwYr54bM3+F0ZLzy4LmxWyypcyPYuZFT1Gh9cvi+b8rCvU6K8hTpw9ms2
 wtuWtDzIPEyAP1A3e7m+hH/c/Gr1oSZZpA+f90y2tHtiGuLtyxpW9FCU5DfzSmrv
 IMU+BHwsmKgiZaAoR99SXlvnmWrH+zxnrOvaludi2zxbzw/PYTG4SGmxiB0od/KS
 uY2jlDjfmlGjd++ON7f4qirr4pSuDs1HTyLaxmfEaNtuME1BMOlBym1/lgdbAVI=
 =JAr9
 -----END PGP SIGNATURE-----
 

Remove consumer unnecessary locks (#9261)

### Motivation
1. The `ConsumerImpl` has many unnecessary locks for thread-safe Queue, such as `Queues.newConcurrentLinkedQueue`, `GrowableArrayBlockingQueue`, `ConcurrentLinkedQueue` 

### Changes
1. Remove unnecessary locks in `ConsumerImpl`

Related to PR#8207