RandomWalkTradeGenerator не хранятся сделки

так у вас памяти не хватает, ведь написано. очищайте этот список, не держите в нём абсолютно все сде...

2012-01-10T19:22:58Z

так у вас памяти не хватает, ведь написано. очищайте этот список, не держите в нём абсолютно все сделки.

Создание шлюза: _trader = new EmulationTrader( new[] , new[] ) ; _trader.DepthGenerators[security] =...

2012-01-10T19:03:44Z

Создание шлюза:

_trader = new EmulationTrader( new[] , new[] ) ; _trader.DepthGenerators[security] = new TrendMarketDepthGenerator(security) ;

из Strategy:

protected override void OnStarting() { sdelki = new ThreadSafeObservableCollection();

          this
                 .When(Security.SecurityNewTrades())
                 .Do(raschet);
       base.OnStarting();
      }

private void raschet() { sdelki.Add(Security.LastTrade);

        MainWindow.Instance.GuiAsync(() => sum_vol_riz010 = sdelki.Where(p => p.Time > Security.LastTrade.Time.AddSeconds(-10) &&
                  p.Security == Security).Sum(tr => tr.Volume));
      }

Пытаюсь сделать, чтобы заработал данный элементарный расчет.

Без стэк трэйса невозможно сказать. Но похоже что да, проблема с потоками у вас возникает в алгоритм...

2012-01-10T18:40:35Z

Без стэк трэйса невозможно сказать. Но похоже что да, проблема с потоками у вас возникает в алгоритме.

Для тестирования также нужны сделки. Пытался обойти данную проблему созданием собственной ThreadSafe...

2012-01-10T16:20:19Z

Для тестирования также нужны сделки. Пытался обойти данную проблему созданием собственной ThreadSafeObservableCollection sdelki, столкнулся со следующим:

по событию

this .When(Security.SecurityNewTrades()) .Do(raschet); сначала идет добавление последней сделки в мою коллекцию, а затем уже необходимый расчет на основе моей коллекции: private void raschet() { sdelki.Add(Security.LastTrade); ... /// Расчет ... }

Если перед запуском делаю остановку на строке добавления сделки в коллекцию и далее прогоняю с пом F11, то сделки сохраняются в коллекцию и расчет идет. Без остановки в коллекцию добавляется только одна сделка, хотя тики продолжают генерироваться и событие срабатывает и через некоторое время вылетает Win32Exception. Так понимаю что-то с потоками...

russ: В самой стратегии пробую считать объем сделок за период, но: Int32 count = base.Trader.Trades....

2011-12-11T10:06:30Z

russ: В самой стратегии пробую считать объем сделок за период, но:

Int32 count = base.Trader.Trades.Count();


Да, в эмуляции сделки не попадают в Trader.Trades.

Народ, так должны хранится сделки или нет? В примерах аналогичная ситуация.

2011-12-11T08:03:12Z

Народ, так должны хранится сделки или нет? В примерах аналогичная ситуация.

Версия 4.0.8 Генерирую данные и стакан. var security = new Security { Id = "RIU9@RTS", Code = "RIU9"...

2011-12-10T19:45:43Z

Версия 4.0.8 Генерирую данные и стакан.

var security = new Security
                    {
                        Id = "RIU9@RTS",
                        Code = "RIU9",
                        Name = "RTS-9.09",
                        MinStepSize = 5,
                        MinStepPrice = 2,
                        Decimals = 0,
                        Exchange = Exchange.Test,
                    };

                    _trader = new EmulationTrader(
                            new[] { security },
                            new[] { portfolio })
                        {
                            MarketTimeChangedInterval = timeFrame
                        };

                        _trader.TradeGenerators[security] = new RandomWalkTradeGenerator(security, 155000);
                        _trader.DepthGenerators[security] = new TrendMarketDepthGenerator(security);

В самой стратегии пробую считать объем сделок за период, но:

Int32 count = base.Trader.Trades.Count();
``` всегда = 0.
Хотя в ```csharp
Trade tr = base.Security.LastTrade;
``` есть информация по сделке.
Приход новых сделок в стратегии обрабатываю вот так:
```csharp
protected override void OnStarting()
        {
            this
                .When(base.Security.SecurityNewTrades())
                .Do(CalcVolume);

            base.OnStarting();
        }

В чем может быть проблема?