Архитектура: парсинг и выгрузка текстовиков

Vector<String> data;
for(int i = 0; i < 100; i++)
    data.Add(AsString(1.0 / i));
 
double sum = 0;
 
std::atomic<int> ii(0);
 
CoDo([&] {
    double m = 0;
    for(int i = ii++; i < data.GetCount(); i = ii++)
        m += atof(data[i]);
    CoWork::FinLock();
    sum += m;
});
 
DUMP(sum);

#include <CtrlLib/CtrlLib.h>
 
using namespace Upp;
 
volatile int manstop = 0;
 
Mutex mtx;
 
struct MainWindow : public TopWindow
{
    Button m_start;
    Button m_cancel;
    StatusBar m_status;
    ProgressIndicator m_progress;
 
    MainWindow()
    {
        Title ( "Тест" );
        Add ( m_start.SetLabel ( "Старт" ).LeftPos ( 10, 80 ).TopPos ( 10, 20 ) );
        Add ( m_cancel.SetLabel ( "Отмена" ).LeftPos ( 10, 80 ).TopPos ( 40, 20 ) );
        Add ( m_progress.LeftPos ( 10, 200 ).TopPos ( 70, 20 ) );
        AddFrame ( m_status );
 
        m_progress.Set ( 0, 100 );
 
        m_cancel.WhenAction = []
        {
            Mutex::Lock __ ( mtx );
            manstop = 1;
        };
    }
};
 
class Worker
{
 
    public:
        void Start ( StatusBar* pstatus,  ProgressIndicator* pprogress );
 
    private:
        StatusBar* m_pstatus;
        ProgressIndicator* m_pprogress;
        Thread m_thread;
        volatile Atomic m_pos;
        void Work();
        void WorkP ( String filename );
};
 
void Worker::Start ( StatusBar* pstatus,  ProgressIndicator* pprogress )
{
    m_pstatus = pstatus;
    m_pprogress = pprogress;
 
    Mutex::Lock __ ( mtx );
    manstop = 0;
 
    m_thread.Run ( [=]{this->Work();} );
 
};
 
void Worker::Work()
{
 
    bool on = true;
    CoWork cw;
    m_pos = 0;
 
    Vector <String> fname;
 
    //Создаем список (вектор) имен файлов
    for ( int i = 0; i < 200; i++ )
        fname << ( IntStr ( i ) + ".txt" );
 
 
    m_pprogress->Set ( 0, fname.GetCount() );
 
    int i = 0;
 
    while ( on )
    {
        if ( i < fname.GetCount() )
        {
            /*Пул потоков*/
            cw & [=, &fname]{this->WorkP ( fname[i] );};
            ++i;
        }
 
        else
        {
            /*Ожидаем завершения пула потоков
            проверяя каждые четвертьсекунды*/
 
            if ( cw.IsFinished() )
            {
                GuiLock __;
                m_pstatus->Set ( "Выполнено" );
                on = false;
            }
 
            else
                Sleep ( 250 );
        }
 
 
 
        Mutex::Lock __ ( mtx );
 
        if ( manstop == 1 )//Проверяем на отмену
        {
 
            if ( !cw.IsFinished() )
                cw.Cancel();//Отменяем задания для пула
 
            on = false;
            GuiLock __;
            m_pstatus->Set ( "Отмена" );
            m_pprogress->Set ( 0 );
 
        }
    }
 
};
 
    
void Worker::WorkP ( String filename )
{
    /*Этот код выполняется параллельно*/
    
    
    /*Выполняется какая-то
    длительная обработка*/
    Sleep ( Random() % 2000 );
 
 
    /*Результат передается в GUI*/
    GuiLock __;
    m_pstatus->Set ( filename );
    m_pprogress->Set ( AtomicInc ( m_pos ) );
 
};
 
 
 
GUI_APP_MAIN
{
    Worker worker;
    MainWindow w;
 
    w.m_start.WhenAction = [&worker, &w]
    {
        worker.Start ( &w.m_status, &w.m_progress );
    };
    w.SetRect ( 0, 0, 300, 200 );
    w.Run();
}