Amebis/wxWidgets
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed several bugs in threading code for OS/2. Thread sample now working.

Browse Source 
git-svn-id: https://svn.wxwidgets.org/svn/wx/wxWidgets/trunk@23307 c3d73ce0-8a6f-49c7-b76d-6d57e0e08775
This commit is contained in:
Stefan Neis
2003-08-30 20:44:14 +00:00
parent ba87f54c0d
commit f877815e1b
2 changed files with 56 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
include/wx/thread.h
View File

@@ -732,7 +732,7 @@ public:
#if wxUSE_THREADS
#if defined(__WXMSW__) || defined(__WXMAC__) || defined(__WXPM__)
#if defined(__WXMSW__) || defined(__WXMAC__) || defined(__WXPM__) || defined(__EMX__)
// unlock GUI if there are threads waiting for and lock it back when
// there are no more of them - should be called periodically by the main
// thread

84
src/os2/thread.cpp
View File

@@ -377,7 +377,7 @@ public:
TID GetId() const { return m_hThread; }
// thread function
static DWORD OS2ThreadStart(ULONG ulParam);
static void OS2ThreadStart(void* pParam);
private:
// Threads in OS/2 have only an ID, so m_hThread is both it's handle and ID
@@ -388,16 +388,20 @@ private:
unsigned int m_nPriority; // thread priority in "wx" units
};
ULONG wxThreadInternal::OS2ThreadStart(
ULONG ulParam
void wxThreadInternal::OS2ThreadStart(
void * pParam
)
{
DWORD dwRet;
bool bWasCancelled;
// first of all, check whether we hadn't been cancelled already and don't
// start the user code at all then
wxThread *pThread = (wxThread *)ulParam;
wxThread *pThread = (wxThread *)pParam;
// first of all, wait for the thread to be started.
pThread->m_critsect.Enter();
pThread->m_critsect.Leave();
// Now check whether we hadn't been cancelled already and don't
// start the user code at all in this case.
if ( pThread->m_internal->GetState() == STATE_EXITED )
{
dwRet = (DWORD)-1;
@@ -425,7 +429,7 @@ ULONG wxThreadInternal::OS2ThreadStart(
delete pThread;
}
//else: the joinable threads handle will be closed when Wait() is done
return dwRet;
return;
}
void wxThreadInternal::SetPriority(
@@ -468,20 +472,20 @@ bool wxThreadInternal::Create(
, unsigned int uStackSize
)
{
APIRET ulrc;
ulrc = ::DosCreateThread( &m_hThread
,(PFNTHREAD)wxThreadInternal::OS2ThreadStart
,(ULONG)pThread
,CREATE_SUSPENDED | STACK_SPARSE
,(ULONG)uStackSize
);
if(ulrc != 0)
int tid;
if (!uStackSize)
uStackSize = 131072;
pThread->m_critsect.Enter();
tid = _beginthread(wxThreadInternal::OS2ThreadStart,
NULL, uStackSize, pThread);
if(tid == -1)
{
wxLogSysError(_("Can't create thread"));
return FALSE;
}
m_hThread = tid;
if (m_nPriority != WXTHREAD_DEFAULT_PRIORITY)
{
SetPriority(m_nPriority);
@@ -509,7 +513,7 @@ bool wxThreadInternal::Resume()
if (ulrc != 0)
{
wxLogSysError(_("Can not suspend thread %lu"), m_hThread);
wxLogSysError(_("Can not resume thread %lu"), m_hThread);
return FALSE;
}
@@ -527,8 +531,6 @@ bool wxThreadInternal::Resume()
// static functions
// ----------------
bool WXDLLEXPORT wxGuiOwnedByMainThread();
wxThread *wxThread::This()
{
wxThread* pThread = m_pThread;
@@ -651,6 +653,13 @@ wxThreadError wxThread::Pause()
wxThreadError wxThread::Resume()
{
if (m_internal->GetState() == STATE_NEW)
{
m_internal->SetState(STATE_RUNNING);
m_critsect.Leave();
return wxTHREAD_NO_ERROR;
}
wxCriticalSectionLocker lock((wxCriticalSection &)m_critsect);
return m_internal->Resume() ? wxTHREAD_NO_ERROR : wxTHREAD_MISC_ERROR;
@@ -745,25 +754,42 @@ wxThreadError wxThread::Delete(ExitCode *pRc)
}
}
result = ::DosWaitThread(&hThread, DCWW_WAIT);
result = ::DosWaitThread(&hThread, DCWW_NOWAIT);
// FIXME: We ought to have a message processing loop here!!
switch ( result )
{
case ERROR_INTERRUPT:
case ERROR_THREAD_NOT_TERMINATED:
break;
case ERROR_INVALID_THREADID:
// error
wxLogSysError(_("Can not wait for thread termination"));
Kill();
return wxTHREAD_KILLED;
case NO_ERROR:
// thread we're waiting for terminated
break;
// thread we're waiting for just terminated
// or even does not exist any more.
result = NO_ERROR;
break;
default:
wxFAIL_MSG(wxT("unexpected result of DosWaitThread"));
}
if ( IsMain() )
{
// event processing - needed if we are the main thread
// to give other threads a chance to do remaining GUI
// processing and terminate cleanly.
wxTheApp->HandleSockets();
if (wxTheApp->Pending())
if ( !wxTheApp->DoMessage() )
{
// WM_QUIT received: kill the thread
Kill();
return wxTHREAD_KILLED;
}
else
wxUsleep(10);
}
else
wxUsleep(10);
} while ( result != NO_ERROR );
#else // !wxUSE_GUI
// simply wait for the thread to terminate
@@ -830,7 +856,7 @@ void wxThread::Exit(
)
{
delete this;
::DosExit(EXIT_THREAD, ULONG(pStatus));
_endthread();
wxFAIL_MSG(wxT("Couldn't return from DosExit()!"));
}