window7 iis建立网站,网站制作专家,建设网站需要哪些资质,做网站 就上凡科建站当将CDI与异步执行方法#xff08;例如ManagedExecutorService #xff0c;传统上不可能访问在原始线程中处于活动状态的所有CDI范围。 MicroProfile Context Propagation可以定义线程执行上下文并将其传递到完成阶段#xff0c;尽管我们的代码是异步执行的#xff0c;但它… 当将CDI与异步执行方法例如ManagedExecutorService 传统上不可能访问在原始线程中处于活动状态的所有CDI范围。 MicroProfile Context Propagation可以定义线程执行上下文并将其传递到完成阶段尽管我们的代码是异步执行的但它们仍可以访问各种CDI上下文。 另外Context Propagation允许创建托管的执行器服务该服务可以注入到我们的bean中并在其中使用例如实现舱壁。 增强的CDI上下文 让我们创建并使用在处理请求期间使用的请求范围的Bean。 使用普通的CDI我们将无法在异步执行中访问和查找bean。 看下面的代码 ApplicationScoped Path ( contexts/example ) public class ThreadContextExampleResource { Inject ExampleStore exampleStore; Inject ThreadContext threadContext; Resource ManagedExecutorService mes; Inject Notifier notifier; PUT public void setExample(String example) { exampleStore.setExample(example); mes.execute(threadContext.contextualRunnable(notifier::notifyAbout)); } } RequestScoped public class ExampleStore { private String example; public String getExample() { return example; } public void setExample(String example) { this .example example; } } public class Notifier { Inject ExampleStore exampleStore; public void notifyAbout() { System.out.println( New example: exampleStore.getExample()); } } 如果客户端PUT向contexts/example资源提供了某些内容则该方法将使用ManagedExecutorService更新请求范围的ExampleStore bean并异步执行通知。 为了使异步执行能够查找请求范围的存储我们使用ThreadContext将可运行对象与从原始线程捕获的上下文进行包装。 这样可以确保执行的可运行对象可以使用相应的上下文。 我们必须根据要传播的上下文类型例如CDI transaction security 配置并产生ThreadContext public class ThreadContextProducer { Produces ThreadContext threadContext() { return ThreadContext.builder() .propagated(ThreadContext.ALL_REMAINING) .build(); } } 本示例将所有上下文类型传播到包装的执行中。 然后我们的bean注入并使用产生的ThreadContext 。 使用执行程序定义舱壁 MicroProfile Context Propagation允许创建和配置ManagedExecutor 这是类似于ManagedExecutorService的容器管理的执行器服务。 我们可以通过编程方式创建ManagedExecutor 对允许的并发设置约束并定义上下文传播。 通过使用专用执行器来实现特定功能我们可以实现隔板模式类似于使用MicroProfile Fault Tolerance或Porcupine 。 让我们定义以下异步JAX-RS资源 ApplicationScoped Path ( bulkheads ) public class BulkheadExampleResource { Inject ExampleStore exampleStore; Inject Notifier notifier; Inject ManagedExecutor writeExecutor; Inject ManagedExecutor readExecutor; GET public CompletionStageString example() { return readExecutor.supplyAsync(exampleStore::getExample); } PUT public CompletionStageVoid setExample(String example) { return writeExecutor.runAsync(() - { exampleStore.setExample(example); writeExecutor.execute(notifier::notifyAbout); }); } } 我们正在注入两个专用的执行器它们用于运行相应的功能。 执行者是使用生产者创建的 public class ManagedExecutorProducer { Produces ManagedExecutor managedExecutor() { return ManagedExecutor.builder() .propagated(ThreadContext.CDI, ThreadContext.APPLICATION) .maxAsync( 4 ) .maxQueued( 4 ) .build(); } public void disposeManagedExecutor( Disposes ManagedExecutor managedExecutor) { managedExecutor.shutdownNow(); } } 我们的执行者将具有四个同时执行的完成阶段和四个任务的上限。 CDI的上下文和应用程序上下文类型将传播到执行线程。 注入执行程序时请注意注入点的范围 这里我们使用的是应用程序范围的资源否则我们可能会创建两个以上的执行程序这将违反隔板模式的目的。 由于我们使用的是CDI因此如果应以不同的方式配置所创建的执行程序则当然可以定义其他限定符。 您可以使用最新版本的Open Liberty试用MicroProfile Context Propagation。 我已经在GitHub上发布了一个示例存储库。 当我们在Open Liberty上运行应用程序时MicroProfile Context Propagation执行程序将由自动调整的全局线程池提供支持。 你可以看看由自由所提供的默认线程池的指标如图所示这里 。 更多资源 GitHub示例项目 MicroProfile上下文传播 开放自由中的上下文传播支持 使用Prometheus和Grafana监视开放自由 翻译自: https://www.javacodegeeks.com/2019/08/enhanced-cdi-contexts-bulkheads-microprofile-context-propagation.html
