the-james-burton/the-turbine

ensure indicators and strategies are computed after the tick is received

the-james-burton opened this issue · 3 comments

RabbitMQ multicasts the tick to four destinations in the turbine-condenser. At present, the processing order is not guaranteed for these, so the indicators and strategies may be computed on a Ta4J TimeSeries that does not have the tick in it. This should be fixed

Done with a CountDownLatch mapped to tick timestamp to enable the indicators and strategies to wait for their tick to be received.

Also added a sneaky bit of synchonized for better concurrency when a new Ticker is being setup.

Just need to setup a cleanup for the map.

Actually, change the map to a caffeine cache!

Done and works nicely... closing.