网站建设方案就玄苏州久远网络,wordpress mysql主机名,网站的根目录,张家港高端网站建设公司几个月前#xff0c;我发布了一个出版物 #xff0c;在其中详细解释了我提出的名为Outcome的抽象#xff0c;它通过强制使用语义帮助了我很多 没有副作用的代码。 通过遵循这种简单#xff08;但功能强大#xff09;的约定#xff0c;我最终将任何类型的故障#xff08;… 几个月前我发布了一个出版物 在其中详细解释了我提出的名为Outcome的抽象它通过强制使用语义帮助了我很多 没有副作用的代码。 通过遵循这种简单但功能强大的约定我最终将任何类型的故障又称Exception都转化为函数的显式结果从而使一切都更容易推论。 我不认识您但是我厌倦了处理会破坏一切的异常因此我做了一些事情老实说它确实工作得很好。 因此在继续讲故事之前我真的建议您仔细阅读该文章。 现在让我们使用古怪的应用思想解决一些异步问题对吧 这样邪恶的事情来了 生活真是太好了我们的编码像以往一样快速干净和可组合但是出乎意料的是我们偶然发现了一个“缺失”功能请大笑一下我们需要将几个异步 结果实例合并到一个阻碍时尚…。 受到这个想法的鼓舞我开始工作。 我尝试了很多时间以寻求一种健壮而又简单的方式来表达这种情况。 虽然新的ComposableFuture API原来比我期望的要好得多尽管我仍然不明白为什么他们决定使用诸如applyAsync或thenComposeAsync之类的名称而不是map或flatMap 但我总是以实现过于冗长和重复比较的方式结束我在Scala上所做的一些事情但是经过很长的“ Mate ”课程之后我有了“嘿 一刻”为什么不使用类似于应用程序的内容 问题 假设我们有两个异步结果 CompletableFutureOutcomeString textf completedFuture(maybe(And the number is %s!));CompletableFutureOutcomeInteger numberf completedFuture(maybe(22)); 还有一个愚蠢的实体Message public static class Message{private final String _text;private final Integer _number;private Message(String msg, Integer number){_text msg;_number number;}public String getContent(){return String.format(_text,_number);}
} 我需要给定textf和numberf的东西它会给我类似的东西 //After combining textf and numberf
CompletableFutureOutcomeMessage message .... 所以我给圣诞老人写了一封信 我想仅当两个值都可用时才使用numberf返回的数字异步格式化textf返回的字符串这意味着两个期货均成功完成并且所有结果均未失败。 当然我们需要不 阻塞。 如果发生故障我想收集在执行textf和/或numberf期间发生的所有故障然后再次将它们返回给调用方而不会阻塞。 我不想受到要组合的值数的限制它必须能够处理大量的异步结果。 我是说没有阻止吗 你去... 尝试期间不死。 适用于救援人员 如果您考虑一下那么一种简单的方法来表达我们想要实现的目标如下 // Given a String - Given a number - Format the message
f: String - Integer - Message 检查f的定义它表示类似“给出一个String 我将返回一个以Integer作为参数的函数该函数在应用时将以这种方式返回Message类型的实例而不是等待所有值一次可用我们可以一次部分应用一个值以获得对Message实例构造过程的实际描述。 听起来不错。 要实现这一点如果我们可以使用构造lambda Messagenew并对其进行咖喱 再说一次boomdone !将是非常了不起的但是在Java中这是不可能的以一种通用美观和简洁的方式进行因此对于为了我们的示例我决定采用我们钟爱的Builder模式该模式确实可以胜任 public static class Builder implements WannabeApplicativeMessage {private String _text;private Integer _number;public Builder text(String text){_texttext;return this;}public Builder number(Integer number){_numbernumber;return this;}Overridepublic Message apply() {return new Message(_text,_number);}
} 这是WannabeApplicative T的定义 public interface WannabeApplicativeV
{V apply();
} Disclamer 对于那些功能 怪癖 这本身并不是适用的我知道但是我从中汲取了一些想法并根据语言提供给我的工具对其进行了调整。 因此如果您感到好奇请查看此帖子以获取更正式的示例。 如果您仍在我身边我们可以同意到目前为止我们并没有做过任何复杂的事情但是现在我们需要表达一个构建步骤记住该步骤必须是无阻塞的并且能够合并以前发生的任何故障可能发生在其他可能有新执行的处决中。 因此为了做到这一点我提出了以下内容 public static class CompositionSourcesB
{private CompositionSources(){ }public interface PartialB{CompletableFutureOutcomeB apply(CompletableFutureOutcomeB b);}public interface MergingStageB, V{PartialB by(BiFunctionOutcomeB, OutcomeV, OutcomeB f);}public V MergingStageB, V value(CompletableFutureOutcomeV value){return f - builder- builder.thenCombine(value, (b, v) - f.apply(b, v).dependingOn(b).dependingOn(v));}public static B CompositionSourcesB stickedTo(ClassB clazz){return new CompositionSources();}
} 首先我们有两个功能接口一个是Partial B 它表示将值懒惰地应用于生成器 而第二个接口MergingStage BV表示“如何”组合既是建设者又是价值 。 然后我们得到了一个名为value的方法给定类型为CompletableFuture Outcome V 的实例它将返回类型为MergingStage BV的实例并且信不信由你这就是发生魔术的地方。 如果您还记得MergingState定义 则将看到它是BiFunction 其中第一个参数的类型为Outcome B 第二个参数的类型为Outcome V 。 现在如果遵循这些类型则可以说出两件事一侧的构建过程的部分状态类型参数B和需要应用于构建器当前状态的新值类型参数V以便在应用时将生成一个新的构建器实例该实例具有“构建顺序中的下一个状态”由Partial B表示 。 最后但并非最不重要的一点我们有stickedTo方法它基本上是一个糟糕的Java技巧可在定义构建步骤时坚持使用特定的应用程序类型构建器。 例如具有 CompositionSourcesBuilder sources CompositionSources.stickedTo(Builder.class); 我可以为任何Builder实例定义部分值应用程序如下所示 //What were gonna do with the async text when available
PartialBuilder textToApply sources.value(textf).by((builder, text) - builder.flatMapR(b - text.mapR(b::text)));//Same thing for the number
PartialBuilder numberToApply sources.value(numberf).by((builder, number) - builder.flatMapR(b - number.mapR(b::number))); 看到我们还没有建立任何东西我们只是描述了当时间到时我们想对每个值进行的操作 我们可能想在使用新值之前进行一些验证这是在结果发挥重要作用时或者只是使用确实如此这完全取决于我们但主要要点是我们还没有应用任何东西。 为了这样做并最终收紧所有松散的末端我想出了其他一些定义如下所示 public static class FutureCompositionsV , A extends WannabeApplicativeV{private final SupplierCompletableFutureOutcomeA _partial;private FutureCompositions(SupplierCompletableFutureOutcomeA state){_partialstate;}public FutureCompositionsV, A binding(PartialA stage){return new FutureCompositions(() - stage.apply(_partial.get()));}public CompletableFutureOutcomeV perform(){return _partial.get().thenApply(p - p.mapR(WannabeApplicative::apply));}public static V, A extends WannabeApplicativeV FutureCompositionsV, A begin(A applicative){return new FutureCompositions(() - completedFuture(maybe(applicative)));}
} 希望这不是那么令人头疼但我会尽力将其分解得尽可能清楚。 为了开始指定如何将整个事物组合在一起您将从调用WannabeApplicative V类型的实例开始 在我们的示例中它的类型参数V等于Builder 。 FutureCompositionsMessage, Builder ab begin(Message.applicative()) 看到在调用begin之后 您将获得一个FutureCompositions的新实例其中包含一个延迟评估的部分状态 使其成为整个构建过程状态的唯一所有者而这正是我们所做的一切的最终目标到目前为止我们已经做好了充分的控制以完全控制何时以及如何将事物组合在一起。 接下来我们必须指定要合并的值这就是绑定方法的用途 ab.binding(textToApply).binding(numberToApply); 这样我们便可以使用先前定义的Partial实例为构建器实例提供所有需要合并的值以及每个实例应该发生的情况的规范。 还可以看到所有内容仍在惰性评估中什么都没有发生但是我们仍然堆叠了所有“步骤”直到最终确定实现结果为止这将在您调用perform时发生。 CompletableFutureOutcomeMessage message ab.perform(); 从那一刻起一切都会展开每个构建阶段都将得到评估可以在结果实例中返回并收集故障或者简单地将新可用的值以一种或另一种方式提供给目标构建器实例所有步骤将被执行直到什么都不做。 我将尝试描述如下情况 如果您留意图片的左侧您可以轻松地看到我之前显示的每个步骤是如何“定义的”遵循先前的“声明”箭头方向即您实际描述构建过程的方式。 现在从您调用perform的那一刻起每个应用实例在我们的情况下请记住Builder 将被反方向延迟求值它将首先求值堆栈中的最后一个指定阶段然后再求值下一个阶段依次类推直到达到建筑物定义的“起点”它将开始展开或向上逐步展开评估并使用MergingStage规范收集所有可能的信息 。 而这仅仅是个开始…。 我敢肯定可以做很多事情来改善这个想法例如 连续两次调用CompositionSources.values的 dependingOn 很烂 我觉得这太冗长了我必须对此做些事情。 我不太确定要继续将结果实例传递给MergingStage 如果在调用它之前解开要合并的值并只返回Either FailureV 它将看起来更干净更轻松-这将降低复杂性并提高灵活性关于幕后发生的事情。 尽管使用Builder模式完成了这项工作但是感觉还是很老套了 我很想轻松地构造函数因此在我的待办事项清单中是检查jOOλ或Javaslang是否可以提供某些服务。 更好的类型推断以便从代码中消除任何不必要的干扰例如 stickedTo方法它的确是代码的味道我一开始就讨厌。 绝对需要更多时间来找出从定义本身推断应用类型的另一种方法。 非常欢迎您给我发送您可能有的任何建议和意见。 干杯记住…… 翻译自: https://www.javacodegeeks.com/2015/12/composing-multiple-async-results-via-applicative-builder-java-8.html
