管道流monad状态
管道流（Monad）是一种函数式编程中的概念，用于处理函数的组合和复合。它可以将多个函数连接在一起，形成一个函数链，每个函数的输出作为下一个函数的输入。通过这种方式，可以简化代码的编写和维护，并提高代码的可读性和可复用性。
管道流的优势在于它可以将复杂的问题分解为多个简单的函数，每个函数只负责完成一个特定的任务，使得代码更加模块化和可测试。此外，管道流还可以避免中间变量的使用，减少了代码的冗余和错误的可能性。
管道流在各种编程语言中都有相应的实现，例如在JavaScript中可以使用lodash或Ramda库来实现管道流。在函数式编程中，管道流被广泛应用于数据处理、异步编程、错误处理等场景。
在云计算领域，管道流的概念可以应用于数据流处理、任务调度、日志处理等场景。例如，可以使用管道流来处理大规模数据的清洗、转换和分析，将数据从一个环节传递到另一个环节，实现数据的流式处理和实时计算。
腾讯云提供了一些相关的产品和服务，可以用于支持管道流的实现和应用。例如，腾讯云的云函数（Serverless Cloud Function）可以用于编写和部署函数，实现函数的组合和复合。腾讯云的消息队列（Message Queue）可以用于实现任务的调度和消息的传递。腾讯云的日志服务（Cloud Log Service）可以用于收集和分析日志数据。
腾讯云云函数产品介绍链接：https://cloud.tencent.com/product/scf
腾讯云消息队列产品介绍链接：https://cloud.tencent.com/product/cmq
腾讯云日志服务产品介绍链接：https://cloud.tencent.com/product/cls
相关·内容
我正在学习Haskell，并试图找出实现视线算法的最常用的方法。
我找到的演示代码使用了state monad，但对我(我只是个初学者)来说，递归传递state似乎更简单。这里我漏掉了什么？是否存在性能问题？
在以下位置查找代码：
谢谢,
克里斯。
浏览 3提问于2009-09-21得票数 9
回答已采纳
我想要定义一个函数，它需要一个Int，根据数字(x)在控制台中打印一个错误，然后用Nothing更新State。
如何在一个函数中加入这些命令？
我得到的是：
type Env = [(Variable,Int)]
newtype StateError a = StateError { runStateError :: Env -> Maybe (a, Env) }
class Monad m => MonadError m where
throw :: Monad m => a -> m a
instance MonadError State
浏览 0提问于2018-12-15得票数 1
回答已采纳
1回答
我正在尝试创建一个可以消耗多个输入流的管道。我需要能够等待一个或另一个输入流以不特定的顺序(例如，不交替)使压缩无用。这里没有任何平行或不确定的事情发生:我在一条或另一条河流上等待。我希望能够编写类似于以下内容的代码(其中awaitA和awaitB分别等待第一个或第二个输入流)：
do
_ <- awaitA
x <- awaitA
y <- awaitB
yield (x,y)
_ <- awaitB
_ <- awaitB
y' <- awaitB
yield (x,y')
我所拥有的最好的解决方案是把内部
浏览 0提问于2013-03-24得票数 9
我只是重新发明了一些monad，但我不确定是哪一个。它允许您对计算的步骤进行建模，因此您可以交错大量计算的步骤，以找出哪个计算最先完成。
{-# LANGUAGE ExistentialQuantification #-}
module Computation where
-- model the steps of a computation
data Computation a = forall b. Step b (b -> Computation a) | Done a
instance Monad Computation where
(Step b g) >>
浏览 4提问于2011-08-29得票数 26
回答已采纳
假设我正在设计一个跟踪其内部状态的库，并且希望允许用户添加自己的自定义状态。为此目的，用户期望拥有什么样的界面？
更准确地说，这个问题主要是将独立的状态添加到现有的状态中，这样状态的范围(或生命周期)将保持不变。
浏览 1提问于2018-06-03得票数 0
回答已采纳
2回答
我希望听到比我更深入了解、和之间的根本区别以及主要优点和缺点的人的意见。一些 ，但如果能有一个高层次的概述就更好了。
浏览 2提问于2012-04-03得票数 34
回答已采纳
1回答
我正在尝试使用解析器编写一个Conduit。具体地说，在给定parseOne :: Parser T的情况下，我想构造一个Conduit ByteString m T，它重复地将解析器应用于输入并流式传输结果。
提供了sinkParser来将Parser转换为Sink，但如何将此Sink转换为Conduit？我要找的函数如下：
conduitSink :: (Resource m) => Sink a m b -> Conduit a m b
它反复将数据输入到Sink中，并在运行过程中生成每个结果。它看起来可以很容易地写成一个手动循环，但我想知道是否有更好的方法。
管道库中缺少这
浏览 0提问于2012-01-28得票数 7
回答已采纳
我一直在尝试编写我的第一个“真正的”haskell程序，这个程序的目的是最终从表单的页面中抓取有关电影的信息。我做这方面的第一步是创建一个函数，它能够从两个日期之间查询每周的信息。我想出的代码不起作用，错误消息超出了我目前的haskell能力。
守则：
import Network.HTTP.Conduit
import Data.Time.Clock
import Data.Time.Calendar.WeekDate
import Data.Time.Calendar (Day, addDays, fromGregorian)
import Control.Monad.Trans.Reso
浏览 5提问于2013-09-23得票数 2
回答已采纳
1回答
我正在尝试这样做：
processListIO :: [A] -> IO [B]
processListIO xs = bracket ini fin $ \s -> mapM (upd s) xs
where
ini :: IO (Ptr S)
upd :: Ptr S -> A -> IO B
fin :: Ptr S -> IO ()
基本上，这是一个迭代列表的计算，将每个元素映射到其他元素，并在过程中使用内部私有状态。我脑海中的特定ini、upd和fin来自一个C库，但它们被保证“行为良好”，因为它们只是分配新的状态，执行一个唯
浏览 3提问于2020-10-17得票数 1
我有以下正在融合在一起的线管构件：
awaitVals () :: ConduitT (Element mono) (Element mono) m ()
intermTmp :: forall o. (Element mono -> Bool) -> ConduitT (Element mono) o m ([Element mono])
融合发生的方式如下：awaitVals () .| intermTmp curPred。
根据fuse函数(.|)，我认为这里的类型应该是可以的。Fuse是：
(.|) :: Monad m
=> ConduitT a b m
浏览 13提问于2019-09-26得票数 1
在定价部分，Google说每个员工的PD值是默认的(取决于批处理和流)。我正在运行一个作业，考虑到我有多少工作人员(与默认的PD使用相比)，持久磁盘使用的数量要比应该的高得多。这在多个不同的作业中是一致的。是什么导致PD使用量增加的？作为参考，默认为480 GB的流媒体工作者，但我被收费5888 GB。
浏览 2提问于2017-07-13得票数 1
回答已采纳
2回答
具有下列有状态的使用者：
consumer1 :: Consumer a (StateT b m) ()
在execStateT的帮助下，将其转换为下面的方法的最佳方法是什么？
consumer2 :: Consumer a m b
浏览 7提问于2014-07-14得票数 3
回答已采纳
可以使用streams (惰性列表)从多个源(简单地说是两个)拉取需求。迭代器可用于处理来自单一来源的数据。
是否有一个类似Iteratee的函数概念来处理多个输入源？我可以想象一个Iteratee，它想要从哪个源拉出其状态信号。
浏览 0提问于2012-09-19得票数 11
回答已采纳
在haskell 中，有一个复制的例子。
>>> (S.toList . mapped S.toList . chunksOf 5) $ (S.toList . mapped S.toList . chunksOf 3) $ S.copy $ each [1..10]
[[1,2,3,4,5],[6,7,8,9,10]] :> ([[1,2,3],[4,5,6],[7,8,9],[10]] :> ())
是否有可能把它分成两个“干净”的流，这样就可以打印下面的结果？
>>>S.print stream1
[[1,2,3,4,5],[6,7,8,
浏览 1提问于2020-02-18得票数 1
回答已采纳
1回答
我们正在考虑使用Beam/Dataflow进行有状态处理，但对状态后端有限的可见性有点担心。如果内存不足，如何将状态持久化到磁盘上？有潜在的数据库吗？
我在2021年的活动1中听说过风车，但2019年的一张罚单是指持久化磁盘。
谢谢！
浏览 2提问于2021-11-04得票数 0
回答已采纳
1回答
溪流与单体
、、、、
流(惰性列表)和单一列表之间有什么区别吗？从概念和数学的角度来看，而不是从技术实现的角度。
或者说，两者之间是否存在一对一的对应关系？
更确切地说，作为流，它的意思是“偶数流”来自的Scheme语言。
这是另一个类别而不是单元组？如果是，那是哪一类呢？
“甚至溪流”能保证副作用的控制吗，就像单元组一样？
浏览 5提问于2012-05-07得票数 15
2回答
因此，我最近一直在研究state，因为我想在haskell中构建一个解析器组合器库。
我偶然发现了一个名为MonadState的类型，我想知道这个类型的意义是什么，你会在哪里使用它？
浏览 5提问于2016-08-24得票数 0
回答已采纳
我想做一个Haskell函数，它可以从给定的列表中挑选出一个随机数。我的类型签名是：
randomPick :: [a] -> a
我该怎么办？
浏览 0提问于2010-05-28得票数 22
我正在尝试用管道编写一个webscraper，并且我已经开始使用下面的刮掉的链接了。我有一个process函数，它下载一个url，查找链接并生成它们。
process :: Pipe Item Item (StateT CState IO) ()
....
for (each links) yield
....
现在，我想知道如何递归地遵循这些链接，线程StateT通过。我意识到，在刮板中使用单个管道(尤其是当我开始添加更多功能时)，我可能会做一些更惯用的事情，我愿意接受建议。在考虑多线程/共享状态时，我可能不得不重新考虑设计。
浏览 3提问于2016-07-21得票数 3
回答已采纳
我想让warp运行一个进程，然后用该进程的输出进行响应。假设输出大于服务器的RAM；加载整个输出，然后响应不是一个选项。我想我可以用这样的方法来完成
withProcessWait_ (setStdout createSource "cat largefile") (pure . responseSource ok200 [] . getStdout)
但使用ConduitT i (Flush Builder) IO ()，使用ConduitT i ByteString m ()。我不知道如何将ByteString管道转换为Flush Builder管道。
因此，我设计了一个
浏览 3提问于2019-09-03得票数 0
回答已采纳
我看了一些关于State monad的教程，我想我明白了。
例如，在中
import Data.Word
type LCGState = Word32
lcg :: LCGState -> (Integer, LCGState)
lcg s0 = (output, s1)
where s1 = 1103515245 * s0 + 12345
output = fromIntegral s1 * 2^16 `div` 2^32
getRandom :: State LCGState Integer
getRandom = get >>= \s0 -
浏览 2提问于2009-07-13得票数 4
回答已采纳
1回答
我正在探索使用管道包的可能性，以便在Haskell中实现复杂的事件处理。例如，我想使用管道实现一个累加函数。
从以下方面开始：
#!/usr/bin/env stack
-- stack script --resolver lts-8.12 --package conduit-combinators
{-# LANGUAGE ExtendedDefaultRules #-}
import Conduit
trans :: Monad m => ConduitM Int Int m ()
trans = do
mapC (* 2)
main :: IO ()
main = ru
浏览 0提问于2018-03-12得票数 3
回答已采纳
1回答
流分配器实现细节
、、
在查看WrappingSpliterator::trySplit的源代码时，我被它的实现误导了：
@Override
public Spliterator<P_OUT> trySplit() {
if (isParallel && buffer == null && !finished) {
init();
Spliterator<P_IN> split = spliterator.trySplit();
return (split
浏览 1提问于2019-04-02得票数 6
回答已采纳
3回答
我需要我的状态被传递，同时能够将功能与可能的工作流程相链接。有没有办法让两个工作流共享相同的上下文？如果不是，方法是什么？
更新：
嗯，我有一个状态，它代表了我要在数据库中创建的实体的一段可用ID。因此，一旦获得了一个ID，就必须将该状态转换为具有下一个可用ID的较新状态，并将其丢弃，以便没有人可以再次使用它。我不想为了表达习惯而改变状态。State monad看起来像是一种方法，因为它隐藏了转换并传递了状态。一旦状态工作流就位，我就不能使用我在任何地方都使用的可能工作流。
浏览 2提问于2013-10-02得票数 1
2回答
在java 8中，当我这么做的时候，
类型1
list.stream().parallel().map(/**/).unordered().filter(/**/).collect(/**/);
类型2
list.stream().parallel().unordered().map(/**/).filter(/**/).collect(/**/);
由于这两个流都是并行的，我可以理解每个操作的所有对象，如filter、map等。将以并行方式执行，但操作本身将按定义的顺序顺序执行。
问题
1.在Type1中，我确实说map()操作后无序()。那么，map()操作是否尝试处理“排序”，因为它在u
浏览 0提问于2019-06-09得票数 2
回答已采纳
当一个ResumableSource不是Monad的实例时，如何将它们附加到另一个？下面是一个玩具示例-- a有Monad约束，而b没有它。所以我们可以附加a's，而不是b's
Prelude> import Data.Conduit
Prelude Data.Conduit> import Data.ByteString as BS
Prelude Data.Conduit BS> import Control.Monad.Trans.Resource
Prelude Data.Conduit BS Control.Monad.Trans.Resource
浏览 2提问于2016-06-21得票数 1
回答已采纳
将Observable.lift(operator: Operator)定义为：
创建一个新的可观测性，该可观测性作为源，而传递的算子被定义为新的可观测的算子。
Observable.pipe(operations: ...*)为：
用于将功能操作符缝合成一条链。返回所有按传递顺序调用的操作符的可观察结果。
因此很明显，.pipe可以接受多个操作符，而.lift不能接受。但是pipe也可以接受一个操作符，所以这不是唯一的区别。从文档本身来看，我不清楚它们的目的是什么以及它们存在的原因。，请有人解释一下这些函数的用途，以及每个函数何时使用？
迄今为止的观察
以下代码(打字本)：
浏览 0提问于2018-02-22得票数 20
4回答
虽然我之前做了一些修改，但我创建了以下代码：
newtype Callback a = Callback { unCallback :: a -> IO (Callback a) }
liftCallback :: (a -> IO ()) -> Callback a
liftCallback f = let cb = Callback $ \x -> (f x >> return cb) in cb
runCallback :: Callback a -> IO (a -> IO ())
runCallback cb =
do re
浏览 2提问于2013-02-06得票数 16
回答已采纳
1回答
我有一个父windows窗体应用程序和子commandline.exe。使用匿名管道(h)的修改后的MSDN示例，我可以将一个序列化的对象从父对象发送给子对象。子对象可以反序列化对象并读取值。
也许我误解了匿名管道的机制，但是我希望管道保持打开，直到我关闭它，这样我就可以在我喜欢的时候发送另一个对象，但是在发送/接收对象之后，管道不再连接(由IsConnected属性确定)。
此时，一旦对象从父对象发送到子对象，管道就会关闭(而不是由“me”关闭)。我在本地维护了对原始pipeHandle的引用，但似乎无法重新打开管道。我是不是应该在一开始就关闭它？我不知道如何打开另一个新管道，因为我不能将句
浏览 1提问于2011-01-27得票数 5
我一直在阅读关于DataFlow如何在流中读取数据时破坏消息。根据和的答案，似乎DataFlow 'ack‘是按包发送的消息，只要它完成了这个包，那么它就会’打包‘其中的消息。
混淆n是当管道中涉及到一个GroupByKey时会发生什么。包中的数据将持久化到多区域桶中，并且消息将被确认。那就想象一下整个地区都会垮掉。中间数据仍将在桶中(因为我们多区域)。
话虽如此，
为了避免丢失任何数据，应该遵循哪些步骤？关于如何处理这种主动/主动方法的建议，以便在一个区域完全关闭时不松散数据？
请告诉我，
浏览 2提问于2020-03-10得票数 2
回答已采纳
2回答
我试图理解管道概念的不同实现之间的差异。管道和管道的区别之一是它们是如何将管道融合在一起的。导管
(>+>) :: Monad m
=> Pipe l a b r0 m r1 -> Pipe Void b c r1 m r2 -> Pipe l a c r0 m r2
而管道
(>->) :: (Monad m, Proxy p)
=> (b' -> p a' a b' b m r) -> (c' -> p b' b c' c m r) -> c
浏览 1提问于2013-03-06得票数 10
回答已采纳
我正试图通过编写我自己的pipes函数来学习sum包，现在我遇到了困难。我不想使用来自Pipes.Prelude的实用程序函数(因为它有sum和fold以及其他使其变得微不足道的函数)，而只使用Pipes.Tutorial中描述的信息。本教程没有讨论Proxy的构造函数，但是如果我查看sum和fold的源代码，它使用这些构造函数，我想知道是否有可能在不了解这些低级细节的情况下编写sum函数。
我很难接受这个函数如何能够继续接受值，只要有可用的值，然后以某种方式将该和返回给用户。我想这种类型是：
sum' :: Monad m => Consumer Int m Int
在我看来，
浏览 5提问于2016-02-01得票数 8
回答已采纳
为什么我们的函数需要接受状态和输入，而不仅仅是包含输入的状态(或者包含状态的输入？)
我假设您可能希望在相同的状态下应用不同的输入，因此您希望将它们分开保存，但这是唯一的原因吗？
我觉得我错过了一些基本的东西，但我无法理解。
浏览 0提问于2014-02-26得票数 2
回答已采纳
1回答
吹嘘它的操作符(节点)是“无状态的”。这使得斯派克的体系结构可以使用更简单的协议来实现恢复、负载平衡和处理散乱人员。
另一方面，将其操作符描述为“有状态的”，并声称对于机器学习之类的应用程序来说，状态性是必要的。然而，星火计划能够在RDDs中传递信息和维护应用程序数据，而无需维护“状态”。
这里发生了什么事？星火不是一个真正的无国籍系统吗？或者，Flink关于状态性对于机器学习和类似应用程序至关重要的说法是否不正确？还是这里还有其他细微差别？
我不觉得我真的感觉到了“有状态”和“无状态”系统之间的区别，如果能够解释的话，我会很感激。
浏览 1提问于2018-03-03得票数 6
2回答
这个简单的函数叫什么？
、、、、
你已经看过下面的函数了吗？叫什么来着？它有什么用呢？是否可以比仅针对StateT更通用地定义它
simpleFunction (StateT f) = StateT $ (\s -> return (f s, s))
顺便说一句，ghc给它的类型是Monad n => StateT s m a -> StateT s n (m (a, s))。
还有另一种定义：
simpleFunction m = do
s <- get
mapStateT (\l -> return (l, s)) m
浏览 2提问于2014-08-05得票数 4
1回答
我试图在google数据流上运行一个有状态聚合DoFn，它在其能力矩阵中引用有状态DoFns，但是我得到了以下错误：
异常:请求执行有状态DoFn，但没有可用的用户状态上下文。这可能意味着当前运行程序不支持有状态DoFns的执行。
前面的错误发生在这里：
@with_input_types(Dict[K, V])
@with_output_types(Dict[K, V])
class StatefulCombineDoFn(beam.DoFn):
BUFFER = BagStateSpec(
'buffer',
Pickle
浏览 0提问于2019-06-01得票数 2
1回答
目标 我正在尝试编写解释器的内部结构，出于人体工程学的目的，我认为我想要一个既能像状态又能像monad那样工作的monad。 例如，我想用这两种风格做一些事情： checkedAddress :: Integer -> Interpreter Int
checkedAddress n = if (n < toInteger (minBound :: Int))
then fail $ "Address " ++ show n ++ " is too low"
else
浏览 16提问于2019-12-09得票数 3
回答已采纳
上下文
我目前正在阅读有关Clojure的monads实现的文章: org.clojure/algo.monads
直观地说，reduce看起来像一个应用于map的state-m。基本上，有一个"state“，它是到目前为止的值。
现在，我不能用“标准的方式”来工作，因为：
(domonad state-m
[ ... I can only stuff a constant number of things here ...
... but I need to stuff here a list whose size is only known at run time
浏览 0提问于2012-06-18得票数 1
回答已采纳
7回答
我是haskell，函数式语言和monads的新手。
一个月来，我一直在玩这个游戏；我读过，还在玩snap，试图让我的haskell网站。
但是有件事困扰着我:单体的抽象。如果我理解正确的话，monads就是可以排序的“数据容器”。例如，我可以用">>=“来”解压“它，并且会为我做更多的”幕后“工作，这样如果我没有单一的定义，我就必须猜测它是如何被解压的。
例如：
我们有一个列表单，解压它将对它的元素排序。
[1,2,3] >>= return . (+1) -- gives back [2,3,4]
或者像这些例子中的作者那样更复杂的单曲：
或者我可能有一个w
浏览 4提问于2013-09-10得票数 6
回答已采纳
4回答
在其中一个示例中使用了以下两个函数：
stdout :: () -> Consumer String IO r
stdout () = forever $ do
str <- request ()
lift $ putStrLn str
stdin :: () -> Producer String IO ()
stdin () = loop
where
loop = do
eof <- lift $ IO.hIsEOF IO.stdin
unless eof $ do
浏览 0提问于2013-06-24得票数 9
回答已采纳
5回答
Haskell是一种纯函数式编程语言。
我的问题是：使用Haskell来解决涉及大量状态的问题(例如GUI编程或游戏编程)的优缺点是什么？
还有一个次要问题:以功能方式处理状态有哪些方法？
提前谢谢。
浏览 2提问于2010-10-15得票数 14
回答已采纳
我写了一些玩具代码来玩弄箭头的概念。我想看看我是否可以编写一个箭头来编码有状态函数的概念-在不同的调用后给出不同的值。
{-# LANGUAGE Arrows#-}
module StatefulFunc where
import Control.Category
import Control.Arrow
newtype StatefulFunc a b = SF { unSF :: a -> (StatefulFunc a b, b) }
idSF :: StatefulFunc a a
idSF = SF $ \a -> (idSF, a)
dotSF :: State
浏览 0提问于2010-09-10得票数 17
回答已采纳
1回答
我正在尝试获得一个简单的示例，但在类型检查阶段失败了。在中，我看到ResourceT被用作管道“执行者”，如果这有意义的话。我也知道，一段时间以来，ResourceT一直是。然而，我仍然无法找到一个简单的例子。下面是我的代码，它是受启发的
import qualified Data.Conduit as C
import qualified Data.Conduit.Binary as CB
import qualified Data.Conduit.List as CL
import Control.Monad.Trans.Resource (runResourceT)
import Dat
浏览 2提问于2014-09-10得票数 1
回答已采纳
我刚刚开始学习Haskell，我的问题可能是一个琐碎的问题，所以很抱歉打扰你。
因此，假设我有一个真正的无限数据源(例如stdin)，并且我想使用Repa或Accelerate的并行工具来处理数据。它们都使用数组(有限数据结构)。在我看来，我的代码将处理数组序列，但我真的不知道该怎么做，然后我需要从一个数组和下一个数组中获得一些数据来计算一些东西。
所以，我的意思是，如何计算所有输入的y = phase(a[i] * conj a[i+1])，其中a是无限的复数流。
浏览 0提问于2013-11-25得票数 3
我有一个数据流任务，订阅来自PubSub的消息： p.apply("pubsub-topic-read", PubsubIO.readMessagesWithAttributes()
.fromSubscription(options.getPubSubSubscriptionName()).withIdAttribute("uuid")) 我在文档中看到，不能保证不复制，比姆建议使用withIdAttribute。 直到我排空一个现有作业，等待它完成并重新启动另一个作业，然后我看到数以百万计的重复BigQuery记录(我的作业将PubSub消息写入Big
浏览 21提问于2019-04-05得票数 1
1回答
我试图使用管道来建模一个双向Proxy实例最理想的问题。基本上，我有类似于以下架构的内容：
api logic
| ^
| |
v |
A A'
layer 1
B B'
| ^
| |
v |
layer 2
基本上，我有一个layer 1，它是一个双向变压器。该模型是基于拉的，因此我的消息流转换将由从logic组件中的拉触发。
所以我应该让layer1 :: Proxy A' A B' B m x，即layer1从api中提取A，进行一些转换A -> B，然后使用l
浏览 3提问于2017-06-08得票数 0
回答已采纳
我读了一些Haskell的Stack和Queen示例代码(比如：)。他们使Stack和Queen作为国家Monad的实例，使其易于使用。
那么，Haskell的名单能作为国家Monad的例子吗？
但如果不是，为什么？似乎被插入到一个列表中
1:[2,3,4]
就像堆里的第一推。所以
可以作为国家Monad?的实例列出
如果可以的话，为什么Haskell不把它作为State的实例呢？我认为因为它是最常用的数据结构，所以如果将它作为State的实例，就很难使用(与直接使用它相比)
浏览 4提问于2021-06-09得票数 0
回答已采纳
3回答
结合F#异步和可能的计算表达式
、、、、
假设我想在async工作流中返回一个Option：
let run =
async {
let! x = doAsyncThing
let! y = doNextAsyncThing x
match y with
| None -> return None
| Some z -> return Some <| f z
}
理想情况下，我会在异步时使用来自FSharpx的可能计算表达式，以避免执行match。我可以做一个自定义构建器，但是有没有一种方法可以通用地组合两个计算表达式呢
浏览 0提问于2012-09-12得票数 18
回答已采纳
2回答
大多数初学者以命令式的方式编写IO相关任务。在执行IO相关任务时，有没有什么一般性的建议可以帮助初学者切换到更实用的方式？
作为一个具体的示例，请考虑目录遍历和文件处理的任务。对我来说，命令式的方法是遍历目录树，并像C风格的语言一样处理每个文件。然后，我发现了库，对我来说，它代表了函数方式:构建源代码列表，然后使用该列表。
因此，我可以说“管道方式”是IO相关任务中首选的函数式编程方式吗？
浏览 0提问于2014-01-13得票数 4
在我的业务领域-金融机构的后台IT -软件组件携带全局配置，记录其进度，出现某种错误处理/计算短路，这是非常常见的……可以由Haskell中的Reader，Writer，或者可能是monad之类的东西很好地建模，并与monad transformers组合在一起。
但似乎有一些缺点: monad转换器背后的概念相当棘手和难以理解，monad转换器导致非常复杂的类型签名，并且它们会造成一些性能损失。
所以我想知道:在处理上面提到的那些常见任务时，monad transformers是不是最好的实践？
浏览 2提问于2010-05-04得票数 54
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
