Question

我在一份包含以下领域的数据库中记录了实时存货:<代码>Id、、Last和。最后是目前的股票价格(翻一番),在记录价格变动时,<编码> 日标准/代码>为<日码>。



I would like to replay this stream in the same way it came in, meaning if a price change was originally 12 seconds apart then the price change event firing (or something similar) should be 12 seconds apart.

在C# I中,可能产生一种收集,按<代码>Datetime分类,然后使用时间差异引发一场事件,以知道何时发生火灾,以抵消下一个价格变化。我认识到“F#”与事件有关的许多冷却的新障碍,但我不知道我会如何在F#中开始这样做。关于我如何这样做的任何想法/编码信条/有益联系?

Answer 1

我认为你热爱“F#”解决办法:-。

为了保持这一榜样的简单性,我把价格和时间序列储存在包含标记的清单中(第一个要素是从最后更新中推延第二个要素是价格)。很难将你的输入数据输入这一格式。例如:

let prices = [ (0, 10.0); (1000, 10.5); (500, 9.5); (2500, 8.5) ]

现在,我们可以创造新的活动,用于重新开展这一进程。在创立后,我们立即附上一些手稿,以印刷价格更新:

let evt = new Event<float>()
evt.Publish.Add(printfn "Price updated: %f")

最后一个步骤是实施这种再演——这可以采用对价值观的不同步工作流程,不时地等到规定的时间,然后引发事件:

async { for delay, price in prices do
          do! Async.Sleep(delay)
          evt.Trigger(price) }
|> Async.StartImmediate

采用<条码>StartImmediate开始工作,这意味着工作将按目前思路进行(等候时间是同步的,因此不会阻碍铺面)。保持所有单一版本,就更加简单(例如,你可以安全地获得全球倡议的控制)。

http://www.ohchr.org。为了从申请的其他部分中总结某些部分的功能,你可以确定这样的类型:

type ReplyDataStream(prices) =
  let evt = new Event<float>()
  member x.Reply() = 
    // Start the asynchronous workflow here
  member x.PriceChanged = 
    evt.Publish

然后,用户可以通过<代码>stream.PriceChanged.Add.(......)对所记录的变化进行重新分析,然后开始使用<代码>Reply(。

友情链接