Function new_thread_invoke

src/builtin/module_builtin_jobque.cpp:639–659

    }

    void new_thread_invoke ( Lambda lambda, Func fn, int32_t lambdaSize, Context * context, LineInfoArg * lineinfo ) {
        shared_ptr<Context> forkContext;
        forkContext.reset(get_clone_context(context, uint32_t(ContextCategory::thread_clone)));
        forkContext->sharedPtrContext = true;
        auto ptr = forkContext->allocate(lambdaSize + 16,lineinfo);
        forkContext->heap->mark_comment(ptr, "new [[ ]] in new_thread");
        memset ( ptr, 0, lambdaSize + 16 );
        ptr += 16;
        das_invoke_function<void>::invoke(forkContext.get(), lineinfo, fn, ptr, lambda.capture);
        das_delete<Lambda>::clear(context, lambda);
        g_jobQueTotalThreads ++;
        auto bound = daScriptEnvironment::getBound();
        thread([=]() mutable {
            daScriptEnvironment::setBound(bound);
            Lambda flambda(ptr);
            das_invoke_lambda<void>::invoke(forkContext.get(), lineinfo, flambda);
            das_delete<Lambda>::clear(forkContext.get(), flambda);
            g_jobQueTotalThreads --;
            shutdownThreadLocalDebugAgent();
        }).detach();
    }

    extern condition_variable debugger_stopped;
    extern atomic<bool>       debugger_started;