| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/streadway/amqp/ |
| H A D | consumers.go | 25 type consumers struct { struct
26 sync.WaitGroup // one for buffer
27 closed chan struct{} // signal buffer
29 sync.Mutex // protects below
30 chans consumerBuffers
40 func (subs *consumers) buffer(in chan *Delivery, out chan Delivery) {
71 func (subs *consumers) add(tag string, consumer chan Delivery) {
86 func (subs *consumers) cancel(tag string) (found bool) {
100 func (subs *consumers) close() {
118 func (subs *consumers) send(tag string, msg *Delivery) bool {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ |
| H A D | CompositeJdbcConsumer.java | 34 private final JdbcConsumer[] consumers; field in CompositeJdbcConsumer
39 public CompositeJdbcConsumer(JdbcConsumer[] consumers) { in CompositeJdbcConsumer()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/java/adapter/avro/src/main/java/org/apache/arrow/consumers/ |
| H A D | CompositeAvroConsumer.java | 33 private final List<Consumer> consumers; field in CompositeAvroConsumer
39 public CompositeAvroConsumer(List<Consumer> consumers) { in CompositeAvroConsumer()
|
| /dports/databases/arrow/apache-arrow-6.0.1/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ |
| H A D | CompositeJdbcConsumer.java | 34 private final JdbcConsumer[] consumers; field in CompositeJdbcConsumer
39 public CompositeJdbcConsumer(JdbcConsumer[] consumers) { in CompositeJdbcConsumer()
|
| /dports/databases/arrow/apache-arrow-6.0.1/java/adapter/avro/src/main/java/org/apache/arrow/consumers/ |
| H A D | CompositeAvroConsumer.java | 33 private final List<Consumer> consumers; field in CompositeAvroConsumer
39 public CompositeAvroConsumer(List<Consumer> consumers) { in CompositeAvroConsumer()
|
| /dports/misc/ncnn/ncnn-20211208/tools/pnnx/src/pass_level4/ |
| H A D | dead_code_elimination.cpp | 33 int consumers = 0; in dead_code_elimination() local
79 int consumers = (int)operand->consumers.size(); in dead_code_elimination() local
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/java/adapter/jdbc/src/main/java/org/apache/arrow/adapter/jdbc/consumer/ |
| H A D | CompositeJdbcConsumer.java | 34 private final JdbcConsumer[] consumers; field in CompositeJdbcConsumer
39 public CompositeJdbcConsumer(JdbcConsumer[] consumers) { in CompositeJdbcConsumer()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/java/adapter/avro/src/main/java/org/apache/arrow/consumers/ |
| H A D | CompositeAvroConsumer.java | 33 private final List<Consumer> consumers; field in CompositeAvroConsumer
39 public CompositeAvroConsumer(List<Consumer> consumers) { in CompositeAvroConsumer()
|
| /dports/net/shadowsocks-libev/shadowsocks-libev-3.3.5/libcork/docs/old/ |
| H A D | stream.rst | 147 Built-in stream consumers
165 File stream consumer example
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/util/concurrent/BlockingQueue/ |
| H A D | SingleProducerMultipleConsumerLoops.java | 86 static void run(BlockingQueue<Integer> queue, int consumers, int iters) throws Exception { in run()
91 final int consumers; field in SingleProducerMultipleConsumerLoops
97 SingleProducerMultipleConsumerLoops(BlockingQueue<Integer> queue, int consumers, int iters) { in SingleProducerMultipleConsumerLoops()
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/util/concurrent/BlockingQueue/ |
| H A D | SingleProducerMultipleConsumerLoops.java | 86 static void run(BlockingQueue<Integer> queue, int consumers, int iters) throws Exception { in run()
91 final int consumers; field in SingleProducerMultipleConsumerLoops
97 SingleProducerMultipleConsumerLoops(BlockingQueue<Integer> queue, int consumers, int iters) { in SingleProducerMultipleConsumerLoops()
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/util/concurrent/BlockingQueue/ |
| H A D | SingleProducerMultipleConsumerLoops.java | 86 static void run(BlockingQueue<Integer> queue, int consumers, int iters) throws Exception { in run()
91 final int consumers; field in SingleProducerMultipleConsumerLoops
97 SingleProducerMultipleConsumerLoops(BlockingQueue<Integer> queue, int consumers, int iters) { in SingleProducerMultipleConsumerLoops()
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/util/concurrent/BlockingQueue/ |
| H A D | SingleProducerMultipleConsumerLoops.java | 86 static void run(BlockingQueue<Integer> queue, int consumers, int iters) throws Exception { in run()
91 final int consumers; field in SingleProducerMultipleConsumerLoops
97 SingleProducerMultipleConsumerLoops(BlockingQueue<Integer> queue, int consumers, int iters) { in SingleProducerMultipleConsumerLoops()
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/util/concurrent/BlockingQueue/ |
| H A D | SingleProducerMultipleConsumerLoops.java | 86 static void run(BlockingQueue<Integer> queue, int consumers, int iters) throws Exception { in run()
91 final int consumers; field in SingleProducerMultipleConsumerLoops
97 SingleProducerMultipleConsumerLoops(BlockingQueue<Integer> queue, int consumers, int iters) { in SingleProducerMultipleConsumerLoops()
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/util/concurrent/BlockingQueue/ |
| H A D | SingleProducerMultipleConsumerLoops.java | 86 static void run(BlockingQueue<Integer> queue, int consumers, int iters) throws Exception { in run()
91 final int consumers; field in SingleProducerMultipleConsumerLoops
97 SingleProducerMultipleConsumerLoops(BlockingQueue<Integer> queue, int consumers, int iters) { in SingleProducerMultipleConsumerLoops()
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/util/concurrent/BlockingQueue/ |
| H A D | SingleProducerMultipleConsumerLoops.java | 86 static void run(BlockingQueue<Integer> queue, int consumers, int iters) throws Exception { in run()
91 final int consumers; field in SingleProducerMultipleConsumerLoops
97 SingleProducerMultipleConsumerLoops(BlockingQueue<Integer> queue, int consumers, int iters) { in SingleProducerMultipleConsumerLoops()
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/util/concurrent/BlockingQueue/ |
| H A D | SingleProducerMultipleConsumerLoops.java | 86 static void run(BlockingQueue<Integer> queue, int consumers, int iters) throws Exception { in run()
91 final int consumers; field in SingleProducerMultipleConsumerLoops
97 SingleProducerMultipleConsumerLoops(BlockingQueue<Integer> queue, int consumers, int iters) { in SingleProducerMultipleConsumerLoops()
|
| /dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/lib_rpl/rpl/ |
| H A D | event_stream.h | 88 std::vector<consumer<Value, Error>> consumers; in events() member
124 auto &consumers = copy->consumers; in fire_forward() local
174 const auto &consumers = data->consumers; in fire_error_forward() local
|
| /dports/net-im/dendrite/dendrite-0.5.1/federationsender/consumers/ |
| H A D | roomserver_test.go | 15 package consumers package
|
| /dports/lang/gcc10/gcc-10.3.0/libgo/go/image/png/ |
| H A D | paeth_test.go | 79 copy(pdat1, pdat0)
|
| /dports/audio/polyphone/polyphone-75a5e88/sources/mainwindow/ |
| H A D | tabbar.h | 79 int _leftOffset;
|
| /dports/multimedia/mlt7-qt5/mlt-7.0.1/src/tests/test_repository/ |
| H A D | test_repository.cpp | 46 Properties* consumers = r->consumers(); in ThereAreConsumers() local
|
| /dports/multimedia/mlt6-qt5/mlt-6.26.1/src/tests/test_repository/ |
| H A D | test_repository.cpp | 46 Properties* consumers = r->consumers(); in ThereAreConsumers() local
|
| /dports/multimedia/mlt6/mlt-6.26.1/src/tests/test_repository/ |
| H A D | test_repository.cpp | 46 Properties* consumers = r->consumers(); in ThereAreConsumers() local
|
| /dports/multimedia/mlt7/mlt-7.0.1/src/tests/test_repository/ |
| H A D | test_repository.cpp | 46 Properties* consumers = r->consumers(); in ThereAreConsumers() local
|