|
|
|
@ -458,7 +458,7 @@ public class DisruptorConfig { |
|
|
|
|
|
|
|
|
|
|
|
1. 创建一个DisruptorPublisher类: |
|
|
|
1. 创建一个DisruptorPublisher类: |
|
|
|
|
|
|
|
|
|
|
|
``` |
|
|
|
```java |
|
|
|
Copy code |
|
|
|
Copy code |
|
|
|
public class DisruptorPublisher<T> { |
|
|
|
public class DisruptorPublisher<T> { |
|
|
|
private RingBuffer<T> ringBuffer; |
|
|
|
private RingBuffer<T> ringBuffer; |
|
|
|
|