wxButton::GetDefaultSize() fix

[wxWidgets.git] / samples / thread / test.cpp

diff --git a/samples/thread/test.cpp b/samples/thread/test.cpp
index f8c872f879529a61ad9dcfadf7f771229dc96e80..706ac23584b93f8c2efd8f5d67672c89ecdd86b9 100644 (file)
--- a/samples/thread/test.cpp
+++ b/samples/thread/test.cpp
@@ -48,6 +48,7 @@ public:
     bool OnInit();
 };
 
     bool OnInit();
 };
 

+class MyThread;

 WX_DEFINE_ARRAY(wxThread *, wxArrayThread);
 
 // Define a new frame type
 WX_DEFINE_ARRAY(wxThread *, wxArrayThread);
 
 // Define a new frame type


@@ -66,30 +67,33 @@ public:
     void OnClear(wxCommandEvent& event);
 
     void OnStartThread(wxCommandEvent& event);
     void OnClear(wxCommandEvent& event);
 
     void OnStartThread(wxCommandEvent& event);

+    void OnStartThreads(wxCommandEvent& event);

     void OnStopThread(wxCommandEvent& event);
     void OnPauseThread(wxCommandEvent& event);
     void OnResumeThread(wxCommandEvent& event);
 
     void OnIdle(wxIdleEvent &event);
     void OnStopThread(wxCommandEvent& event);
     void OnPauseThread(wxCommandEvent& event);
     void OnResumeThread(wxCommandEvent& event);
 
     void OnIdle(wxIdleEvent &event);

-    bool OnClose() { return TRUE; }

 
 

-    // called by dying thread
+    // called by dying thread _in_that_thread_context_

     void OnThreadExit(wxThread *thread);
 
     void OnThreadExit(wxThread *thread);
 

-public:
-    wxArrayThread m_threads;
-

 private:
 private:

-    // crit section protects access to the array below
+    // helper function - creates a new thread (but doesn't run it)
+    MyThread *CreateThread();
+
+    // crit section protects access to all of the arrays below

     wxCriticalSection m_critsect;
 
     wxCriticalSection m_critsect;
 

-    // the array of threads which finished (either because they did their work
-    // or because they were explicitly stopped)
-    wxArrayInt m_aToDelete;
+    // all the threads currently alive - as soon as the thread terminates, it's
+    // removed from the array
+    wxArrayThread m_threads;

 
     // just some place to put our messages in
     wxTextCtrl *m_txtctrl;
 
 
     // just some place to put our messages in
     wxTextCtrl *m_txtctrl;
 

+    // remember the number of running threads and total number of threads
+    size_t m_nRunning, m_nCount;
+

     DECLARE_EVENT_TABLE()
 };
 
     DECLARE_EVENT_TABLE()
 };
 


@@ -123,13 +127,17 @@ MyThread::MyThread(MyFrame *frame)
 void MyThread::WriteText(const wxString& text)
 {
     wxString msg;
 void MyThread::WriteText(const wxString& text)
 {
     wxString msg;

-    msg << wxTime().FormatTime() << ": " << text;

 
     // before doing any GUI calls we must ensure that this thread is the only
     // one doing it!
 
     // before doing any GUI calls we must ensure that this thread is the only
     // one doing it!

-    wxMutexGuiLocker guiLocker;
+
+    wxMutexGuiEnter();
+
+    msg << wxTime().FormatTime() << ": " << text;

 
     m_frame->WriteText(msg);
 
     m_frame->WriteText(msg);

+
+    wxMutexGuiLeave();

 }
 
 void MyThread::OnExit()
 }
 
 void MyThread::OnExit()


@@ -168,12 +176,13 @@ enum
 {
     TEST_QUIT          = 1,
     TEST_TEXT          = 101,
 {
     TEST_QUIT          = 1,
     TEST_TEXT          = 101,

-    TEST_ABOUT         = 102,
-    TEST_CLEAR         = 103,
-    TEST_START_THREAD  = 203,
-    TEST_STOP_THREAD   = 204,
-    TEST_PAUSE_THREAD  = 205,
-    TEST_RESUME_THREAD = 206
+    TEST_ABOUT,
+    TEST_CLEAR,
+    TEST_START_THREAD  = 201,
+    TEST_START_THREADS,
+    TEST_STOP_THREAD,
+    TEST_PAUSE_THREAD,
+    TEST_RESUME_THREAD

 };
 
 BEGIN_EVENT_TABLE(MyFrame, wxFrame)
 };
 
 BEGIN_EVENT_TABLE(MyFrame, wxFrame)


@@ -181,6 +190,7 @@ BEGIN_EVENT_TABLE(MyFrame, wxFrame)
     EVT_MENU(TEST_ABOUT, MyFrame::OnAbout)
     EVT_MENU(TEST_CLEAR, MyFrame::OnClear)
     EVT_MENU(TEST_START_THREAD, MyFrame::OnStartThread)
     EVT_MENU(TEST_ABOUT, MyFrame::OnAbout)
     EVT_MENU(TEST_CLEAR, MyFrame::OnClear)
     EVT_MENU(TEST_START_THREAD, MyFrame::OnStartThread)

+    EVT_MENU(TEST_START_THREADS, MyFrame::OnStartThreads)

     EVT_MENU(TEST_STOP_THREAD, MyFrame::OnStopThread)
     EVT_MENU(TEST_PAUSE_THREAD, MyFrame::OnPauseThread)
     EVT_MENU(TEST_RESUME_THREAD, MyFrame::OnResumeThread)
     EVT_MENU(TEST_STOP_THREAD, MyFrame::OnStopThread)
     EVT_MENU(TEST_PAUSE_THREAD, MyFrame::OnPauseThread)
     EVT_MENU(TEST_RESUME_THREAD, MyFrame::OnResumeThread)


@@ -211,6 +221,7 @@ bool MyApp::OnInit()
 
     wxMenu *thread_menu = new wxMenu;
     thread_menu->Append(TEST_START_THREAD, "&Start a new thread");
 
     wxMenu *thread_menu = new wxMenu;
     thread_menu->Append(TEST_START_THREAD, "&Start a new thread");

+    thread_menu->Append(TEST_START_THREADS, "Start &many threads at once");

     thread_menu->Append(TEST_STOP_THREAD, "S&top a running thread");
     thread_menu->AppendSeparator();
     thread_menu->Append(TEST_PAUSE_THREAD, "&Pause a running thread");
     thread_menu->Append(TEST_STOP_THREAD, "S&top a running thread");
     thread_menu->AppendSeparator();
     thread_menu->Append(TEST_PAUSE_THREAD, "&Pause a running thread");


@@ -231,14 +242,16 @@ MyFrame::MyFrame(wxFrame *frame, const wxString& title,
                  int x, int y, int w, int h)
        : wxFrame(frame, -1, title, wxPoint(x, y), wxSize(w, h))
 {
                  int x, int y, int w, int h)
        : wxFrame(frame, -1, title, wxPoint(x, y), wxSize(w, h))
 {

-    CreateStatusBar();
+    m_nRunning = m_nCount = 0;
+
+    CreateStatusBar(2);

 
     m_txtctrl = new wxTextCtrl(this, -1, "", wxPoint(0, 0), wxSize(0, 0),
                                wxTE_MULTILINE | wxTE_READONLY);
 
 }
 
 
     m_txtctrl = new wxTextCtrl(this, -1, "", wxPoint(0, 0), wxSize(0, 0),
                                wxTE_MULTILINE | wxTE_READONLY);
 
 }
 

-void MyFrame::OnStartThread(wxCommandEvent& WXUNUSED(event) )
+MyThread *MyFrame::CreateThread()

 {
     MyThread *thread = new MyThread(this);
 
 {
     MyThread *thread = new MyThread(this);
 


@@ -250,10 +263,52 @@ void MyFrame::OnStartThread(wxCommandEvent& WXUNUSED(event) )
     wxCriticalSectionLocker enter(m_critsect);
     m_threads.Add(thread);
 
     wxCriticalSectionLocker enter(m_critsect);
     m_threads.Add(thread);
 

+    return thread;
+}
+
+void MyFrame::OnStartThreads(wxCommandEvent& WXUNUSED(event) )
+{
+    static wxString s_str;
+    s_str = wxGetTextFromUser("How many threads to start: ",
+                              "wxThread sample",
+                              s_str, this);
+    if ( s_str.IsEmpty() )
+        return;
+
+    size_t count, n;
+    sscanf(s_str, "%u", &count);
+    if ( count == 0 )
+        return;
+
+    wxArrayThread threads;
+
+    // first create them all...
+    for ( n = 0; n < count; n++ )
+    {
+        threads.Add(CreateThread());
+    }
+
+    wxString msg;
+    msg.Printf("%d new threads created.", count);
+    SetStatusText(msg, 1);
+
+    // ...and then start them
+    for ( n = 0; n < count; n++ )
+    {
+        threads[n]->Run();
+    }
+}
+
+void MyFrame::OnStartThread(wxCommandEvent& WXUNUSED(event) )
+{
+    MyThread *thread = CreateThread();
+

     if ( thread->Run() != wxTHREAD_NO_ERROR )
     {
         wxLogError("Can't start thread!");
     }
     if ( thread->Run() != wxTHREAD_NO_ERROR )
     {
         wxLogError("Can't start thread!");
     }

+
+    SetStatusText("New thread started.", 1);

 }
 
 void MyFrame::OnStopThread(wxCommandEvent& WXUNUSED(event) )
 }
 
 void MyFrame::OnStopThread(wxCommandEvent& WXUNUSED(event) )


@@ -265,7 +320,18 @@ void MyFrame::OnStopThread(wxCommandEvent& WXUNUSED(event) )
     }
     else
     {
     }
     else
     {

-        m_threads.Last()->Delete();
+        m_critsect.Enter();
+
+        wxThread *thread = m_threads.Last();
+
+        // it's important to leave critical section before calling Delete()
+        // because delete will (implicitly) call OnThreadExit() which also tries
+        // to enter the same crit section - would dead lock.
+        m_critsect.Leave();
+
+        thread->Delete();
+
+        SetStatusText("Thread stopped.", 1);

     }
 }
 
     }
 }
 


@@ -279,9 +345,15 @@ void MyFrame::OnResumeThread(wxCommandEvent& WXUNUSED(event) )
         n++;
 
     if ( n == count )
         n++;
 
     if ( n == count )

+    {

         wxLogError("No thread to resume!");
         wxLogError("No thread to resume!");

+    }

     else
     else

+    {

         m_threads[n]->Resume();
         m_threads[n]->Resume();

+
+        SetStatusText("Thread resumed.", 1);
+    }

 }
 
 void MyFrame::OnPauseThread(wxCommandEvent& WXUNUSED(event) )
 }
 
 void MyFrame::OnPauseThread(wxCommandEvent& WXUNUSED(event) )


@@ -294,29 +366,21 @@ void MyFrame::OnPauseThread(wxCommandEvent& WXUNUSED(event) )
         n--;
 
     if ( n < 0 )
         n--;
 
     if ( n < 0 )

+    {

         wxLogError("No thread to pause!");
         wxLogError("No thread to pause!");

+    }

     else
     else

+    {

         m_threads[n]->Pause();
         m_threads[n]->Pause();

+
+        SetStatusText("Thread paused.", 1);
+    }

 }
 
 // set the frame title indicating the current number of threads
 void MyFrame::OnIdle(wxIdleEvent &event)
 {
 }
 
 // set the frame title indicating the current number of threads
 void MyFrame::OnIdle(wxIdleEvent &event)
 {

-    // first remove from the array all the threads which died since last call
-    {
-        wxCriticalSectionLocker enter(m_critsect);
-
-        size_t nCount = m_aToDelete.Count();
-        for ( size_t n = 0; n < nCount; n++ )
-        {
-            // index should be shifted by n because we've already deleted 
-            // n-1 elements from the array
-            m_threads.Remove((size_t)m_aToDelete[n] - n);
-        }
-
-        m_aToDelete.Empty();
-    }
-
+    // update the counts of running/total threads

     size_t nRunning = 0,
            nCount = m_threads.Count();
     for ( size_t n = 0; n < nCount; n++ )
     size_t nRunning = 0,
            nCount = m_threads.Count();
     for ( size_t n = 0; n < nCount; n++ )


@@ -325,7 +389,14 @@ void MyFrame::OnIdle(wxIdleEvent &event)
             nRunning++;
     }
 
             nRunning++;
     }
 

-    wxLogStatus(this, "%u threads total, %u running.", nCount, nRunning);
+    if ( nCount != m_nCount || nRunning != m_nRunning )
+    {
+        m_nRunning = nRunning;
+        m_nCount = nCount;
+
+        wxLogStatus(this, "%u threads total, %u running.", nCount, nRunning);
+    }
+    //else: avoid flicker - don't print anything

 }
 
 void MyFrame::OnQuit(wxCommandEvent& WXUNUSED(event) )
 }
 
 void MyFrame::OnQuit(wxCommandEvent& WXUNUSED(event) )


@@ -333,7 +404,9 @@ void MyFrame::OnQuit(wxCommandEvent& WXUNUSED(event) )
     size_t count = m_threads.Count();
     for ( size_t i = 0; i < count; i++ )
     {
     size_t count = m_threads.Count();
     for ( size_t i = 0; i < count; i++ )
     {

-        m_threads[i]->Delete();
+       // We must always use 0 because Delete() calls OnThreadExit() and 
+        // OnThreadExit() removed 0 from the array.
+        m_threads[0]->Delete();

     }
 
     Close(TRUE);
     }
 
     Close(TRUE);


@@ -357,10 +430,7 @@ void MyFrame::OnClear(wxCommandEvent& WXUNUSED(event))
 
 void MyFrame::OnThreadExit(wxThread *thread)
 {
 
 void MyFrame::OnThreadExit(wxThread *thread)
 {

-    int index = m_threads.Index(thread);
-    wxCHECK_RET( index != -1, "unknown thread being deleted??" );
-

     wxCriticalSectionLocker enter(m_critsect);
 
     wxCriticalSectionLocker enter(m_critsect);
 

-    m_aToDelete.Add(index);
+    m_threads.Remove(thread);

 }
 }