Support Board

#include "sierrachart.h"
#include<thread>

/****************************************************************************/

SCDLLName("threadTest")

// A dummy function
void foo(int Z)
{
SCString DebugString;
for (int i = 0; i < Z; i++)
{
DebugString.Format("example thread loop");
// sc.AddMessageToLog(DebugString, 0);
// cout << "Thread using function"
   // " pointer as callable\n";
}
}

/*============================================================================
  This example code calculates a simple moving average (30 period by
  default).
----------------------------------------------------------------------------*/
SCSFExport scsf_SimpMovAvg(SCStudyInterfaceRef sc)
{
  SCSubgraphRef Subgraph_Average = sc.Subgraph[0];
  
  SCInputRef Input_Length = sc.Input[0];
  
std::thread th1(foo, 3);
  // Set configuration variables
  if (sc.SetDefaults)
  {
    // Set the configuration and defaults
    
    sc.GraphName = "Simple Moving Average";
    
    sc.StudyDescription = "Example function for calculating a simple moving average.";
    
    // Set the region to draw the graph in. Region zero is the main
    // price graph region.
    sc.GraphRegion = 0;

    sc.ValueFormat = VALUEFORMAT_INHERITED;
    
    // Set the name of the first subgraph
    Subgraph_Average.Name = "Average";
    
    // Set the color, style and line width for the subgraph
    Subgraph_Average.PrimaryColor = RGB(0,255,0);
    Subgraph_Average.DrawStyle = DRAWSTYLE_LINE;
    Subgraph_Average.LineWidth = 2;
    
    // Set the Length input and default it to 30
    Input_Length.Name = "Length";
    Input_Length.SetInt(30);
    Input_Length.SetIntLimits(1,MAX_STUDY_LENGTH);
    Input_Length.SetDescription("The number of bars to average.");
    
    sc.AutoLoop = 1;
    
    sc.AlertOnlyOncePerBar = true;
    
    // Must return before doing any data processing if sc.SetDefaults is set
    return;
  }
  
  // Do data processing
  
  // Set the index of the first array element to begin drawing at
  sc.DataStartIndex = Input_Length.GetInt() - 1;
  
  
  // Calculate a simple moving average from the base data
  sc.SimpleMovAvg(sc.Close,Subgraph_Average,Input_Length.GetInt());
  
  
  if (sc.CrossOver(Subgraph_Average, sc.Close))
  {
    // Since we are using auto-looping we do not specify the Index parameter.
    sc.SetAlert(1, "Moving average has crossed last price.");
  }
}

std::thread th1(foo, 3);
th1.join();

boost::asio::io_service io_service;
boost::asio::io_service::work work(io_service);
std::vector<std::thread> threads;

s11n_example::client* pClient = reinterpret_cast<s11n_example::client*>(sc.GetPersistentPointer(pClientKeys[0]));

if (pClient == nullptr){
try
{

sc.SetPersistentPointer(pClientKeys[0], new s11n_example::client(io_service, host, port, sc));

auto count = std::thread::hardware_concurrency() * 2;
if (count > 2) count = 2; //debugging shows an excepetion after 2? (on R&D machine); count = 8 while debugging prior to me adding this line

for(int n = 0; n < count; ++n)
{
  threads.emplace_back([&]
{
io_service.run();
};
}
.
.
.

if (sc.LastCallToFunction){
if (pClient == nullptr)
   //do nothing
   int a = 1;
else
{
io_service.stop(); // That's OK, io_context::stop is thread-safe
// work.reset(); compiler can't find?

for(auto& thread : threads)
{
if(thread.joinable())
{
  thread.join();
}
}
delete pClient;
}
}