首页this.dataCarrier = new DataCarrier<>("MetricsAggregateWorker." + modelName, name, 2, 10000); BulkConsumePool.Creator creator = new BulkConsumePool.Creator( name, BulkConsumePool.Creator.recommendMaxSize() * 2, 20); try { ConsumerPoolFactory.INSTANCE.createIfAbsent(name, creator); } catch (Exception e) { throw new UnexpectedException(e.getMessage(), e); } this.dataCarrier.consume(ConsumerPoolFactory.INSTANCE.get(name), new AggregatorConsumer());

this.dataCarrier = new DataCarrier<>("MetricsAggregateWorker." + modelName, name, 2, 10000); BulkConsumePool.Creator creator = new BulkConsumePool.Creator( name, BulkConsumePool.Creator.recommendMaxSize() * 2, 20); try { ConsumerPoolFactory.INSTANCE.createIfAbsent(name, creator); } catch (Exception e) { throw new UnexpectedException(e.getMessage(), e); } this.dataCarrier.consume(ConsumerPoolFactory.INSTANCE.get(name), new AggregatorConsumer());

时间: 2024-04-19 11:30:38 浏览: 161

ember-note-creator

笔记此自述文件概述了在此 Ember 应用程序上进行协作的详细信息。这个应用程序的简短介绍可以很容易地转到这里。先决条件您将需要在您的计算机上正确安装以下东西。（带有 NPM）和安装 git clone <repository>这个仓库切换到新目录 npm install bower install 运行/开发 ember server 在访问您的应用程序。代码生成器使用许多代码生成器，尝试使用ember help generate获取更多详细信息运行测试 ember test ember test --server 建造 ember build （开发） ember build --environment production （生产）部署指定部署应用程序所需的条件。进一步阅读/有用的链接开发浏览器扩展 Firefox 的 ember 检查

这段代码是在创建一个数据载体（DataCarrier）并进行消费。首先，代码使用名称和模型名字创建了一个DataCarrier对象，并将其赋值给this.dataCarrier变量。这个DataCarrier对象的名称是"MetricsAggregateWorker." + modelName，并且设置了一个缓存大小为2，超时时间为10000毫秒。接下来，代码创建了一个BulkConsumePool.Creator对象，并传入了名称、建议的最大大小的两倍和一个消费周期为20。这个BulkConsumePool.Creator对象用于创建一个批量消费线程池。然后，代码使用ConsumerPoolFactory.INSTANCE来检查是否已经存在指定名称的消费者池。如果不存在，就使用之前创建的BulkConsumePool.Creator对象来创建一个新的消费者池。最后，代码调用this.dataCarrier.consume方法来消费数据。它传入了ConsumerPoolFactory.INSTANCE.get(name)作为消费者池，并传入了一个AggregatorConsumer对象作为消费者。这段代码的作用是创建一个数据载体，并将其与特定的消费者池和消费者关联起来，以便进行数据的批量消费。

阅读全文