Threads

This section introduces concurrency-related functions. exchange.Go runs time-consuming calls in the background, and EventLoop waits for concurrent call results and events. These two functions are available in all supported programming languages; the multithreading objects listed below support only JavaScript. ctx.subscribe and ctx.poll are the Docker's WebSocket push interfaces: ctx.subscribe() subscribes to market data, market-wide tickers, or private account data streams and returns a Subscription object (an array of subscription objects when subscribing to multiple instruments at once), while ctx.poll() retrieves push events. ctx.order and ctx.cancel place and cancel orders through the exchange's REST API and return only after receiving the exchange's response; ctx.submit places and cancels orders through the exchange's WebSocket trading API (with support for batch operations), returning immediately after the request is written, with results retrieved as response events through ctx.poll(). JavaScript and Python strategies use the global ctx object, while Rust uses functions with the same names in the ctx module. Subscriptions belong to the thread that initiates them. The main thread and each child thread subscribe and retrieve events independently, and all can place orders. Push streams and REST API methods such as exchange.GetTicker() operate independently. For each exchange's push capabilities, see the Capability Matrix.

The FMZ Quant Trading Platform supports multithreading for JavaScript strategies at the underlying system level and provides the following objects:

Object	Description	Notes
threading	Global multithreading object	Member functions: Thread, getThread, mainThread, etc.
Thread	Thread object	Member functions: peekMessage, postMessage, join, etc.
ThreadLock	Thread lock object	Member functions: acquire, release. Can be passed into the thread environment as an argument to the thread's execution function.
ThreadEvent	Event object	Member functions: set, clear, wait, isSet. Can be passed into the thread environment as an argument to the thread's execution function.
ThreadCondition	Condition variable object	Member functions: notify, notifyAll, wait, acquire, release. Can be passed into the thread environment as an argument to the thread's execution function.
ThreadDict	Dictionary object	Member functions: get, set. Can be passed into the thread environment as an argument to the thread's execution function.
Server	Server object	Returned by threading.Serve(). Member functions: addr, close, stop, join, pending. Can be passed into the thread environment as an argument to the thread's execution function.

In this sectionRead the whole section

Name	Description
exchange.Go	Multi-threaded asynchronous support function that can convert the operations of all supported functions into asynchronous concurrent execution.
EventLoop	Listens for events.
ctx.subscribe	Subscribes to WebSocket push streams.
ctx.poll	Retrieves the next push event from the subscriptions of the current thread, with an optional wait timeout.
ctx.order	Places an order through the exchange's REST API and returns after the exchange returns an order ID.
ctx.cancel	Cancels an order through the exchange's REST API and returns after the exchange confirms the cancellation.
ctx.submit	Places and cancels orders through the exchange's WebSocket trading API: returns a request ID immediately after sending the request, without waiting for the exch…
Subscription (4)	A subscription object, returned by ctx.subscribe, represents a single push subscription stream.
threading (10)	A global multi-threading management tool, providing functions for creating concurrent threads, thread locks, condition variables, and more.
Thread (9)	Represents one thread; created or returned through threading.Thread(), threading.getThread(), threading.mainThread(), threading.currentThread().
ThreadLock (2)	Thread lock object for multi-threaded synchronization processing.
ThreadEvent (4)	Event object for event notification and signal passing between multiple threads.
ThreadCondition (5)	Condition variable object used for implementing synchronization and communication between multiple threads.
ThreadDict (2)	Thread-safe dictionary object for data sharing in multi-threaded environments.
Server (5)	Returned by threading.Serve(); represents a running service.