Method StartCommonGeneration

src/rpc/rpcblockchain.cpp:470–491

    template<typename F>
    void StartCommonGeneration(const int64_t periodIn, const int64_t batchSizeIn, F generateFunc) {

        Stop();

        period = periodIn;
        batchSize = batchSizeIn;
        if (period == 0 || batchSize == 0)
            return;

        // reset message queue according to <period, batchSize>
        // For example, generate 50(batchSize) transactions in 20(period), then
        // we need to prepare 1000 * 10 / 20 * 50 = 25,000 transactions in 10 second.
        // Actually, set the message queue's size to 50,000(double or up to 60,000).
        GenTxQueue::SizeType size       = 1000 * 10 * batchSize * 2 / period;
        GenTxQueue::SizeType actualSize = size > MSG_QUEUE_MAX_LEN ? MSG_QUEUE_MAX_LEN : size;

        generationQueue = std::make_unique<GenTxQueue>(actualSize);

        generateThreads = new boost::thread_group();
        generateThreads->create_thread(generateFunc);
        generateThreads->create_thread(boost::bind(&TpsTester::SendTx, this));
    }


};