-
包装大队列的big_queue_wrapper
资源介绍
big_queue_wrapper
大队列的包装。
Big Queue 包装器通过 take() 函数提供阻塞功能。
take() :- 线程将被阻塞,直到队列中有数据可用。
DrainTo(list,size) :- 将在列表中给出非空元素,最大限制 = 大小。
用法 :-
BigQueueWrapper wrapper = new BigQueueWrapper("/Users/swapnil", "test", new ObjectMapper(), MySerialisableClass.class);
wrapper.enqueue(new MySerialisableClass());
- 上一篇: big_event_002:大事件项目2
- 下一篇: 大屏大数据可视化psd原图