12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061 |
- {
- This file is part of the Free Pascal run time library.
- Copyright (c) 2002 by Peter Vreman,
- member of the Free Pascal development team.
- pthreads threading support implementation
- See the file COPYING.FPC, included in this distribution,
- for details about the copyright.
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
- **********************************************************************}
- {$mode objfpc}
- {$ifdef linux}
- { we can combine both compile-time linking and dynamic loading, in order to:
- a) solve a problem on some systems with dynamically loading libpthread if
- it's not linked at compile time
- b) still enabling dynamically checking whether or not certain functions
- are available (could also be implemented via weak linking)
- }
- {$linklib pthread}
- {$define dynpthreads} // Useless on BSD, since they are in libc
- {$endif}
- { sem_init is best, since it does not consume any file descriptors. }
- { sem_open is second best, since it consumes only one file descriptor }
- { per semaphore. }
- { If neither is available, pipe is used as fallback, which consumes 2 }
- { file descriptors per semaphore. }
- { Darwin doesn't support nameless semaphores in at least }
- { Mac OS X 10.4.8/Darwin 8.8 }
- {$if not defined(darwin) and not defined(iphonesim)}
- {$define has_sem_init}
- {$define has_sem_getvalue}
- {$else }
- {$if defined(darwin) or defined(iphonesim)}
- {$define has_sem_open}
- {$endif}
- {$endif}
- {$if defined(linux) or defined(aix) or defined(android)}
- {$define has_sem_timedwait}
- {$endif}
- unit cthreads;
- interface
- {$S-}
- {$ifndef dynpthreads} // If you have problems compiling this on FreeBSD 5.x
- {$linklib c} // try adding -Xf
- {$if not defined(Darwin) and not defined(iphonesim) and not defined(Android)}
- {$ifndef haiku}
- {$linklib pthread}
- {$endif haiku}
- {$endif darwin}
- {$endif}
- {$define basicevents_with_pthread_cond}
- Procedure SetCThreadManager;
- implementation
- Uses
- BaseUnix,
- unix,
- unixtype,
- initc
- {$ifdef dynpthreads}
- ,dl
- {$endif}
- ;
- {*****************************************************************************
- System unit import
- *****************************************************************************}
- procedure fpc_threaderror; [external name 'FPC_THREADERROR'];
- {*****************************************************************************
- Generic overloaded
- *****************************************************************************}
- { Include OS specific parts. }
- {$i pthread.inc}
- Type PINTRTLEvent = ^TINTRTLEvent;
- TINTRTLEvent = record
- condvar: pthread_cond_t;
- mutex: pthread_mutex_t;
- isset: boolean;
- end;
- TTryWaitResult = (tw_error, tw_semwasunlocked, tw_semwaslocked);
- {*****************************************************************************
- Threadvar support
- *****************************************************************************}
- const
- threadvarblocksize : dword = 0;
- var
- TLSKey,
- CleanupKey : pthread_key_t;
- procedure CInitThreadvar(var offset : dword;size : dword);
- begin
- {$ifdef cpusparc}
- threadvarblocksize:=align(threadvarblocksize,16);
- {$endif cpusparc}
- {$ifdef cpupowerpc}
- threadvarblocksize:=align(threadvarblocksize,8);
- {$endif cpupowerc}
- {$ifdef cpui386}
- threadvarblocksize:=align(threadvarblocksize,8);
- {$endif cpui386}
- {$ifdef cpuarm}
- threadvarblocksize:=align(threadvarblocksize,4);
- {$endif cpuarm}
- {$ifdef cpum68k}
- threadvarblocksize:=align(threadvarblocksize,2);
- {$endif cpum68k}
- {$ifdef cpux86_64}
- threadvarblocksize:=align(threadvarblocksize,16);
- {$endif cpux86_64}
- {$ifdef cpupowerpc64}
- threadvarblocksize:=align(threadvarblocksize,16);
- {$endif cpupowerpc64}
- offset:=threadvarblocksize;
- inc(threadvarblocksize,size);
- end;
- procedure CAllocateThreadVars;
- var
- dataindex : pointer;
- begin
- { we've to allocate the memory from system }
- { because the FPC heap management uses }
- { exceptions which use threadvars but }
- { these aren't allocated yet ... }
- { allocate room on the heap for the thread vars }
- DataIndex:=Pointer(Fpmmap(nil,threadvarblocksize,3,MAP_PRIVATE+MAP_ANONYMOUS,-1,0));
- FillChar(DataIndex^,threadvarblocksize,0);
- pthread_setspecific(tlskey,dataindex);
- end;
- procedure CthreadCleanup(p: pointer); cdecl;
- {$ifdef DEBUG_MT}
- var
- s: string[100]; // not an ansistring
- {$endif DEBUG_MT}
- begin
- {$ifdef DEBUG_MT}
- s := 'finishing externally started thread'#10;
- fpwrite(0,s[1],length(s));
- {$endif DEBUG_MT}
- { clean up }
- DoneThread;
- { the pthread routine that calls us is supposed to do this, but doesn't
- at least on Mac OS X 10.6 }
- pthread_setspecific(CleanupKey,nil);
- end;
- procedure HookThread;
- begin
- { Allocate local thread vars, this must be the first thing,
- because the exception management and io depends on threadvars }
- CAllocateThreadVars;
- { we cannot know the stack size of the current thread, so pretend it
- is really large to prevent spurious stack overflow errors }
- InitThread(1000000000);
- { instruct the pthreads system to clean up this thread when it exits }
- pthread_setspecific(CleanupKey,pointer(1));
- end;
- function CRelocateThreadvar(offset : dword) : pointer;
- var
- P : Pointer;
- begin
- P:=pthread_getspecific(tlskey);
- { a thread which we did not create? }
- if (P=Nil) then
- begin
- HookThread;
- // If this also goes wrong: bye bye threadvars...
- P:=pthread_getspecific(tlskey);
- end;
- CRelocateThreadvar:=P+Offset;
- end;
- procedure CReleaseThreadVars;
- begin
- Fpmunmap(pointer(pthread_getspecific(tlskey)),threadvarblocksize);
- end;
- { Include OS independent Threadvar initialization }
- {*****************************************************************************
- Thread starting
- *****************************************************************************}
- type
- pthreadinfo = ^tthreadinfo;
- tthreadinfo = record
- f : tthreadfunc;
- p : pointer;
- stklen : cardinal;
- end;
- function ThreadMain(param : pointer) : pointer;cdecl;
- var
- ti : tthreadinfo;
- nset: tsigset;
- {$if defined(linux) and not defined(FPC_USE_LIBC)}
- nlibcset: tlibc_sigset;
- {$endif linux/no FPC_USE_LIBC}
- {$ifdef DEBUG_MT}
- // in here, don't use write/writeln before having called
- // InitThread! I wonder if anyone ever debugged these routines,
- // because they will have crashed if DEBUG_MT was enabled!
- // this took me the good part of an hour to figure out
- // why it was crashing all the time!
- // this is kind of a workaround, we simply write(2) to fd 0
- s: string[100]; // not an ansistring
- {$endif DEBUG_MT}
- begin
- {$ifdef DEBUG_MT}
- s := 'New thread started, initing threadvars'#10;
- fpwrite(0,s[1],length(s));
- {$endif DEBUG_MT}
- { unblock all signals we are interested in (may be blocked by }
- { default in new threads on some OSes, see #9073) }
- fpsigemptyset(nset);
- fpsigaddset(nset,SIGSEGV);
- fpsigaddset(nset,SIGBUS);
- fpsigaddset(nset,SIGFPE);
- fpsigaddset(nset,SIGILL);
- {$if defined(linux) and not defined(FPC_USE_LIBC)}
- { sigset_t has a different size for linux/kernel and linux/libc }
- fillchar(nlibcset,sizeof(nlibcset),0);
- if (sizeof(nlibcset)>sizeof(nset)) then
- move(nset,nlibcset,sizeof(nset))
- else
- move(nset,nlibcset,sizeof(nlibcset));
- pthread_sigmask(SIG_UNBLOCK,@nlibcset,nil);
- {$else linux}
- pthread_sigmask(SIG_UNBLOCK,@nset,nil);
- {$endif linux}
- { Allocate local thread vars, this must be the first thing,
- because the exception management and io depends on threadvars }
- CAllocateThreadVars;
- { Copy parameter to local data }
- {$ifdef DEBUG_MT}
- s := 'New thread started, initialising ...'#10;
- fpwrite(0,s[1],length(s));
- {$endif DEBUG_MT}
- ti:=pthreadinfo(param)^;
- dispose(pthreadinfo(param));
- { Initialize thread }
- InitThread(ti.stklen);
- { Start thread function }
- {$ifdef DEBUG_MT}
- writeln('Jumping to thread function');
- {$endif DEBUG_MT}
- ThreadMain:=pointer(ti.f(ti.p));
- DoneThread;
- pthread_exit(ThreadMain);
- end;
- Procedure InitCThreading;
-
- begin
- if (InterLockedExchange(longint(IsMultiThread),ord(true)) = 0) then
- begin
- { We're still running in single thread mode, setup the TLS }
- pthread_key_create(@TLSKey,nil);
- InitThreadVars(@CRelocateThreadvar);
- { used to clean up threads that we did not create ourselves:
- a) the default value for a key (and hence also this one) in
- new threads is NULL, and if it's still like that when the
- thread terminates, nothing will happen
- b) if it's non-NULL, the destructor routine will be called
- when the thread terminates
- -> we will set it to 1 if the threadvar relocation routine is
- called from a thread we did not create, so that we can
- clean up everything at the end }
- pthread_key_create(@CleanupKey,@CthreadCleanup);
- end
- end;
- function CBeginThread(sa : Pointer;stacksize : PtrUInt;
- ThreadFunction : tthreadfunc;p : pointer;
- creationFlags : dword; var ThreadId : TThreadId) : TThreadID;
- var
- ti : pthreadinfo;
- thread_attr : pthread_attr_t;
- begin
- {$ifdef DEBUG_MT}
- writeln('Creating new thread');
- {$endif DEBUG_MT}
- { Initialize multithreading if not done }
- if not IsMultiThread then
- InitCThreading;
- { the only way to pass data to the newly created thread
- in a MT safe way, is to use the heap }
- new(ti);
- ti^.f:=ThreadFunction;
- ti^.p:=p;
- ti^.stklen:=stacksize;
- { call pthread_create }
- {$ifdef DEBUG_MT}
- writeln('Starting new thread');
- {$endif DEBUG_MT}
- pthread_attr_init(@thread_attr);
- {$if not defined(HAIKU) and not defined(ANDROID)}
- {$ifdef solaris}
- pthread_attr_setinheritsched(@thread_attr, PTHREAD_INHERIT_SCHED);
- {$else not solaris}
- pthread_attr_setinheritsched(@thread_attr, PTHREAD_EXPLICIT_SCHED);
- {$endif not solaris}
- {$ifend}
- // will fail under linux -- apparently unimplemented
- pthread_attr_setscope(@thread_attr, PTHREAD_SCOPE_PROCESS);
- // don't create detached, we need to be able to join (waitfor) on
- // the newly created thread!
- //pthread_attr_setdetachstate(@thread_attr, PTHREAD_CREATE_DETACHED);
- // set the stack size
- if (pthread_attr_setstacksize(@thread_attr, stacksize)<>0) or
- // and create the thread
- (pthread_create(ppthread_t(@threadid), @thread_attr, @ThreadMain,ti) <> 0) then
- begin
- dispose(ti);
- threadid := TThreadID(0);
- end;
- CBeginThread:=threadid;
- pthread_attr_destroy(@thread_attr);
- {$ifdef DEBUG_MT}
- writeln('BeginThread returning ',ptrint(CBeginThread));
- {$endif DEBUG_MT}
- end;
- procedure CEndThread(ExitCode : DWord);
- begin
- DoneThread;
- pthread_detach(pthread_t(pthread_self()));
- pthread_exit(pointer(ptrint(ExitCode)));
- end;
- function CSuspendThread (threadHandle : TThreadID) : dword;
- begin
- { pthread_kill(SIGSTOP) cannot be used, because posix-compliant
- implementations then freeze the entire process instead of only
- the target thread. Suspending a particular thread is not
- supported by posix nor by most *nix implementations, presumably
- because of concerns mentioned in E.4 at
- http://pauillac.inria.fr/~xleroy/linuxthreads/faq.html#E and in
- http://java.sun.com/j2se/1.4.2/docs/guide/misc/threadPrimitiveDeprecation.html
- }
- // result := pthread_kill(threadHandle,SIGSTOP);
- result:=dword(-1);
- end;
- function CResumeThread (threadHandle : TThreadID) : dword;
- begin
- result:=dword(-1);
- end;
- procedure sched_yield; cdecl; external 'c' name 'sched_yield';
- procedure CThreadSwitch; {give time to other threads}
- begin
- { At least on Mac OS X, the pthread_yield_np calls through to this. }
- { Further, sched_yield is in POSIX and supported on FreeBSD 4+, }
- { Linux, Mac OS X and Solaris, while the thread-specific yield }
- { routines are called differently everywhere and non-standard. }
- sched_yield;
- end;
- function CKillThread (threadHandle : TThreadID) : dword;
- begin
- pthread_detach(pthread_t(threadHandle));
- {$ifndef android}
- CKillThread := pthread_cancel(pthread_t(threadHandle));
- {$else}
- CKillThread := dword(-1);
- {$endif}
- end;
- function CCloseThread (threadHandle : TThreadID) : dword;
- begin
- result:=0;
- end;
- function CWaitForThreadTerminate (threadHandle : TThreadID; TimeoutMs : longint) : dword; {0=no timeout}
- var
- LResultP: Pointer;
- begin
- pthread_join(pthread_t(threadHandle), @LResultP);
- CWaitForThreadTerminate := dword(LResultP);
- end;
- function CThreadSetPriority (threadHandle : TThreadID; Prio: longint): boolean; {-15..+15, 0=normal}
- begin
- {$Warning ThreadSetPriority needs to be implemented}
- result:=false;
- end;
- function CThreadGetPriority (threadHandle : TThreadID): Integer;
- begin
- {$Warning ThreadGetPriority needs to be implemented}
- result:=0;
- end;
- function CGetCurrentThreadId : TThreadID;
- begin
- CGetCurrentThreadId := TThreadID (pthread_self());
- end;
- {*****************************************************************************
- Delphi/Win32 compatibility
- *****************************************************************************}
- procedure CInitCriticalSection(var CS);
- var
- MAttr : pthread_mutexattr_t;
- res: longint;
- begin
- res:=pthread_mutexattr_init(@MAttr);
- if res=0 then
- begin
- res:=pthread_mutexattr_settype(@MAttr,longint(_PTHREAD_MUTEX_RECURSIVE));
- if res=0 then
- res := pthread_mutex_init(@CS,@MAttr)
- else
- { No recursive mutex support :/ }
- fpc_threaderror
- end
- else
- res:= pthread_mutex_init(@CS,NIL);
- pthread_mutexattr_destroy(@MAttr);
- if res <> 0 then
- fpc_threaderror;
- end;
- procedure CEnterCriticalSection(var CS);
- begin
- if pthread_mutex_lock(@CS) <> 0 then
- fpc_threaderror
- end;
- function CTryEnterCriticalSection(var CS):longint;
- begin
- if pthread_mutex_Trylock(@CS)=0 then
- result:=1 // succes
- else
- result:=0; // failure
- end;
- procedure CLeaveCriticalSection(var CS);
- begin
- if pthread_mutex_unlock(@CS) <> 0 then
- fpc_threaderror
- end;
- procedure CDoneCriticalSection(var CS);
- begin
- { unlock as long as unlocking works to unlock it if it is recursive
- some Delphi code might call this function with a locked mutex }
- while pthread_mutex_unlock(@CS)=0 do
- ;
- if pthread_mutex_destroy(@CS) <> 0 then
- fpc_threaderror;
- end;
- {*****************************************************************************
- Semaphore routines
- *****************************************************************************}
- procedure cSemaphoreWait(const FSem: Pointer);
- var
- res: cint;
- err: cint;
- {$if not defined(has_sem_init) and not defined(has_sem_open)}
- b: byte;
- {$endif}
- begin
- {$if defined(has_sem_init) or defined(has_sem_open)}
- repeat
- res:=sem_wait(PSemaphore(FSem));
- err:=fpgetCerrno;
- until (res<>-1) or (err<>ESysEINTR);
- {$else}
- repeat
- res:=fpread(PFilDes(FSem)^[0], b, 1);
- err:=fpgeterrno;
- until (res<>-1) or ((err<>ESysEINTR) and (err<>ESysEAgain));
- {$endif}
- end;
- {$if defined(has_sem_timedwait)}
- function cSemaphoreTimedWait(const FSem: Pointer; const Timeout: ttimespec): cint;
- var
- res: cint;
- err: cint;
- begin
- repeat
- res:=sem_timedwait(PSemaphore(FSem), @Timeout);
- if res=0 then exit(0);
- err:=fpgetCerrno;
- until err<>ESysEINTR;
- result:=err;
- end;
- {$endif}
- procedure cSemaphorePost(const FSem: Pointer);
- {$if defined(has_sem_init) or defined(has_sem_open)}
- begin
- sem_post(PSemaphore(FSem));
- end;
- {$else}
- var
- writeres: cint;
- err: cint;
- b : byte;
- begin
- b:=0;
- repeat
- writeres:=fpwrite(PFilDes(FSem)^[1], b, 1);
- err:=fpgeterrno;
- until (writeres<>-1) or ((err<>ESysEINTR) and (err<>ESysEAgain));
- end;
- {$endif}
- function cSemaphoreTryWait(const FSem: pointer): TTryWaitResult;
- var
- res: cint;
- err: cint;
- {$if defined(has_sem_init) or defined(has_sem_open)}
- begin
- repeat
- res:=sem_trywait(FSem);
- err:=fpgetCerrno;
- until (res<>-1) or (err<>ESysEINTR);
- if (res=0) then
- result:=tw_semwasunlocked
- else if (err=ESysEAgain) then
- result:=tw_semwaslocked
- else
- result:=tw_error;
- {$else has_sem_init or has_sem_open}
- var
- fds: TFDSet;
- tv : timeval;
- begin
- tv.tv_sec:=0;
- tv.tv_usec:=0;
- fpFD_ZERO(fds);
- fpFD_SET(PFilDes(FSem)^[0],fds);
- repeat
- res:=fpselect(PFilDes(FSem)^[0]+1,@fds,nil,nil,@tv);
- err:=fpgeterrno;
- until (res>=0) or ((res=-1) and (err<>ESysEIntr));
- if (res>0) then
- begin
- cSemaphoreWait(FSem);
- result:=tw_semwasunlocked
- end
- else if (res=0) then
- result:=tw_semwaslocked
- else
- result:=tw_error;
- {$endif has_sem_init or has_sem_open}
- end;
- {$if defined(has_sem_open) and not defined(has_sem_init)}
- function cIntSemaphoreOpen(const name: pchar; initvalue: boolean): Pointer;
- var
- err: cint;
- begin
- repeat
- cIntSemaphoreOpen := sem_open(name,O_CREAT,0,ord(initvalue));
- err:=fpgetCerrno;
- until (ptrint(cIntSemaphoreOpen) <> SEM_FAILED) or (err <> ESysEINTR);
- if (ptrint(cIntSemaphoreOpen) <> SEM_FAILED) then
- { immediately unlink so the semaphore will be destroyed when the }
- { the process exits }
- sem_unlink(name)
- else
- { 0 is a valid for sem_open on some platforms; pointer(-1) shouldn't
- be valid anywhere, even for sem_init }
- cIntSemaphoreOpen:=pointer(-1);
- end;
- {$endif}
- function cIntSemaphoreInit(initvalue: boolean): Pointer;
- {$if defined(has_sem_open) and not defined(has_sem_init)}
- var
- tid: string[31];
- semname: string[63];
- {$endif}
- begin
- {$ifdef has_sem_init}
- cIntSemaphoreInit := GetMem(SizeOf(TSemaphore));
- if sem_init(PSemaphore(cIntSemaphoreInit), 0, ord(initvalue)) <> 0 then
- begin
- FreeMem(cIntSemaphoreInit);
- { 0 is a valid for sem_open on some platforms; pointer(-1) shouldn't
- be valid anywhere, even for sem_init }
- cIntSemaphoreInit:=pointer(-1);
- end;
- {$else}
- {$ifdef has_sem_open}
- { avoid a potential temporary nameclash with another process/thread }
- str(fpGetPid,semname);
- str(ptruint(pthread_self()),tid);
- semname:='/FPC'+semname+'T'+tid+#0;
- cIntSemaphoreInit:=cIntSemaphoreOpen(@semname[1],initvalue);
- {$else}
- cIntSemaphoreInit := GetMem(SizeOf(TFilDes));
- if (fppipe(PFilDes(cIntSemaphoreInit)^) <> 0) then
- begin
- FreeMem(cIntSemaphoreInit);
- { 0 is a valid for sem_open on some platforms; pointer(-1) shouldn't
- be valid anywhere, even for sem_init }
- cIntSemaphoreInit:=pointer(-1);
- end
- else if initvalue then
- cSemaphorePost(cIntSemaphoreInit);
- {$endif}
- {$endif}
- end;
- function cSemaphoreInit: Pointer;
- begin
- cSemaphoreInit:=cIntSemaphoreInit(false);
- end;
- procedure cSemaphoreDestroy(const FSem: Pointer);
- begin
- {$ifdef has_sem_init}
- sem_destroy(PSemaphore(FSem));
- FreeMem(FSem);
- {$else}
- {$ifdef has_sem_open}
- sem_close(PSemaphore(FSem));
- {$else has_sem_init}
- fpclose(PFilDes(FSem)^[0]);
- fpclose(PFilDes(FSem)^[1]);
- FreeMem(FSem);
- {$endif}
- {$endif}
- end;
- type
- TPthreadCondition = pthread_cond_t;
- TPthreadMutex = pthread_mutex_t;
- Tbasiceventstate=record
- FCondVar: TPthreadCondition;
- FEventSection: TPthreadMutex;
- FWaiters: longint;
- FIsSet,
- FManualReset,
- FDestroying : Boolean;
- end;
- plocaleventstate = ^tbasiceventstate;
- // peventstate=pointer;
- Const
- wrSignaled = 0;
- wrTimeout = 1;
- wrAbandoned= 2;
- wrError = 3;
- function IntBasicEventCreate(EventAttributes : Pointer; AManualReset,InitialState : Boolean;const Name : ansistring):pEventState;
- var
- MAttr : pthread_mutexattr_t;
- res : cint;
- begin
- new(plocaleventstate(result));
- plocaleventstate(result)^.FManualReset:=AManualReset;
- plocaleventstate(result)^.FWaiters:=0;
- plocaleventstate(result)^.FDestroying:=False;
- plocaleventstate(result)^.FIsSet:=InitialState;
- res := pthread_cond_init(@plocaleventstate(result)^.FCondVar, nil);
- if (res <> 0) then
- begin
- FreeMem(result);
- fpc_threaderror;
- end;
- res:=pthread_mutexattr_init(@MAttr);
- if res=0 then
- begin
- res:=pthread_mutexattr_settype(@MAttr,longint(_PTHREAD_MUTEX_RECURSIVE));
- if Res=0 then
- Res:=pthread_mutex_init(@plocaleventstate(result)^.feventsection,@MAttr)
- else
- res:=pthread_mutex_init(@plocaleventstate(result)^.feventsection,nil);
- end
- else
- res:=pthread_mutex_init(@plocaleventstate(result)^.feventsection,nil);
- pthread_mutexattr_destroy(@MAttr);
- if res <> 0 then
- begin
- pthread_cond_destroy(@plocaleventstate(result)^.FCondVar);
- FreeMem(result);
- fpc_threaderror;
- end;
- end;
- procedure Intbasiceventdestroy(state:peventstate);
- begin
- { safely mark that we are destroying this event }
- pthread_mutex_lock(@plocaleventstate(state)^.feventsection);
- plocaleventstate(state)^.FDestroying:=true;
- { send a signal to all threads that are waiting }
- pthread_cond_broadcast(@plocaleventstate(state)^.FCondVar);
- pthread_mutex_unlock(@plocaleventstate(state)^.feventsection);
- { now wait until they've finished their business }
- while (plocaleventstate(state)^.FWaiters <> 0) do
- cThreadSwitch;
- { and clean up }
- pthread_cond_destroy(@plocaleventstate(state)^.Fcondvar);
- pthread_mutex_destroy(@plocaleventstate(state)^.FEventSection);
- dispose(plocaleventstate(state));
- end;
- procedure IntbasiceventResetEvent(state:peventstate);
- begin
- pthread_mutex_lock(@plocaleventstate(state)^.feventsection);
- plocaleventstate(state)^.fisset:=false;
- pthread_mutex_unlock(@plocaleventstate(state)^.feventsection);
- end;
- procedure IntbasiceventSetEvent(state:peventstate);
- begin
- pthread_mutex_lock(@plocaleventstate(state)^.feventsection);
- plocaleventstate(state)^.Fisset:=true;
- if not(plocaleventstate(state)^.FManualReset) then
- pthread_cond_signal(@plocaleventstate(state)^.Fcondvar)
- else
- pthread_cond_broadcast(@plocaleventstate(state)^.Fcondvar);
- pthread_mutex_unlock(@plocaleventstate(state)^.feventsection);
- end;
- function IntbasiceventWaitFor(Timeout : Cardinal;state:peventstate) : longint;
- var
- timespec: ttimespec;
- errres: cint;
- isset: boolean;
- tnow : timeval;
- begin
- { safely check whether we are being destroyed, if so immediately return. }
- { otherwise (under the same mutex) increase the number of waiters }
- pthread_mutex_lock(@plocaleventstate(state)^.feventsection);
- if (plocaleventstate(state)^.FDestroying) then
- begin
- pthread_mutex_unlock(@plocaleventstate(state)^.feventsection);
- result := wrAbandoned;
- exit;
- end;
- { not a regular inc() because it may happen simulatneously with the }
- { interlockeddecrement() at the end }
- interlockedincrement(plocaleventstate(state)^.FWaiters);
- //Wait without timeout using pthread_cond_wait
- if Timeout = $FFFFFFFF then
- begin
- while (not plocaleventstate(state)^.FIsSet) and (not plocaleventstate(state)^.FDestroying) do
- pthread_cond_wait(@plocaleventstate(state)^.Fcondvar, @plocaleventstate(state)^.feventsection);
- end
- else
- begin
- //Wait with timeout using pthread_cont_timedwait
- fpgettimeofday(@tnow,nil);
- timespec.tv_sec := tnow.tv_sec + (clong(timeout) div 1000);
- timespec.tv_nsec := (clong(timeout) mod 1000)*1000000 + tnow.tv_usec*1000;
- if timespec.tv_nsec >= 1000000000 then
- begin
- inc(timespec.tv_sec);
- dec(timespec.tv_nsec, 1000000000);
- end;
- errres:=0;
- while (not plocaleventstate(state)^.FDestroying) and (not plocaleventstate(state)^.FIsSet) and (errres<>ESysETIMEDOUT) do
- errres:=pthread_cond_timedwait(@plocaleventstate(state)^.Fcondvar, @plocaleventstate(state)^.feventsection, @timespec);
- end;
- isset := plocaleventstate(state)^.FIsSet;
- { if ManualReset=false, reset the event immediately. }
- if (plocaleventstate(state)^.FManualReset=false) then
- plocaleventstate(state)^.FIsSet := false;
- //check the results...
- if plocaleventstate(state)^.FDestroying then
- Result := wrAbandoned
- else
- if IsSet then
- Result := wrSignaled
- else
- begin
- if errres=ESysETIMEDOUT then
- Result := wrTimeout
- else
- Result := wrError;
- end;
- pthread_mutex_unlock(@plocaleventstate(state)^.feventsection);
- { don't put this above the previous pthread_mutex_unlock, because }
- { otherwise we can get errors in case an object is destroyed between }
- { end of the wait/sleep loop and the signalling above. }
- { The pthread_mutex_unlock above takes care of the memory barrier }
- interlockeddecrement(plocaleventstate(state)^.FWaiters);
- end;
- function intRTLEventCreate: PRTLEvent;
- var p:pintrtlevent;
- begin
- new(p);
- if not assigned(p) then
- fpc_threaderror;
- if pthread_cond_init(@p^.condvar, nil)<>0 then
- begin
- dispose(p);
- fpc_threaderror;
- end;
- if pthread_mutex_init(@p^.mutex, nil)<>0 then
- begin
- pthread_cond_destroy(@p^.condvar);
- dispose(p);
- fpc_threaderror;
- end;
- p^.isset:=false;
- result:=PRTLEVENT(p);
- end;
- procedure intRTLEventDestroy(AEvent: PRTLEvent);
- var p:pintrtlevent;
- begin
- p:=pintrtlevent(aevent);
- pthread_cond_destroy(@p^.condvar);
- pthread_mutex_destroy(@p^.mutex);
- dispose(p);
- end;
- procedure intRTLEventSetEvent(AEvent: PRTLEvent);
- var p:pintrtlevent;
- begin
- p:=pintrtlevent(aevent);
- pthread_mutex_lock(@p^.mutex);
- p^.isset:=true;
- pthread_cond_signal(@p^.condvar);
- pthread_mutex_unlock(@p^.mutex);
- end;
- procedure intRTLEventResetEvent(AEvent: PRTLEvent);
- var p:pintrtlevent;
- begin
- p:=pintrtlevent(aevent);
- pthread_mutex_lock(@p^.mutex);
- p^.isset:=false;
- pthread_mutex_unlock(@p^.mutex);
- end;
- procedure intRTLEventWaitFor(AEvent: PRTLEvent);
- var p:pintrtlevent;
- begin
- p:=pintrtlevent(aevent);
- pthread_mutex_lock(@p^.mutex);
- while not p^.isset do pthread_cond_wait(@p^.condvar, @p^.mutex);
- p^.isset:=false;
- pthread_mutex_unlock(@p^.mutex);
- end;
- procedure intRTLEventWaitForTimeout(AEvent: PRTLEvent;timeout : longint);
- var
- p : pintrtlevent;
- errres : cint;
- timespec : ttimespec;
- tnow : timeval;
- begin
- p:=pintrtlevent(aevent);
- fpgettimeofday(@tnow,nil);
- timespec.tv_sec:=tnow.tv_sec+(timeout div 1000);
- timespec.tv_nsec:=(timeout mod 1000)*1000000 + tnow.tv_usec*1000;
- if timespec.tv_nsec >= 1000000000 then
- begin
- inc(timespec.tv_sec);
- dec(timespec.tv_nsec, 1000000000);
- end;
- errres:=0;
- pthread_mutex_lock(@p^.mutex);
- while (not p^.isset) and
- (errres <> ESysETIMEDOUT) do
- begin
- errres:=pthread_cond_timedwait(@p^.condvar, @p^.mutex, @timespec);
- end;
- p^.isset:=false;
- pthread_mutex_unlock(@p^.mutex);
- end;
- type
- threadmethod = procedure of object;
- Function CInitThreads : Boolean;
- begin
- {$ifdef DEBUG_MT}
- Writeln('Entering InitThreads.');
- {$endif}
- {$ifndef dynpthreads}
- Result:=True;
- {$else}
- Result:=LoadPthreads;
- {$endif}
- ThreadID := TThreadID (pthread_self());
- {$ifdef DEBUG_MT}
- Writeln('InitThreads : ',Result);
- {$endif DEBUG_MT}
- // We assume that if you set the thread manager, the application is multithreading.
- InitCThreading;
- end;
- Function CDoneThreads : Boolean;
- begin
- {$ifndef dynpthreads}
- Result:=True;
- {$else}
- Result:=UnloadPthreads;
- {$endif}
- end;
- Var
- CThreadManager : TThreadManager;
- Procedure SetCThreadManager;
- begin
- With CThreadManager do begin
- InitManager :=@CInitThreads;
- DoneManager :=@CDoneThreads;
- BeginThread :=@CBeginThread;
- EndThread :=@CEndThread;
- SuspendThread :=@CSuspendThread;
- ResumeThread :=@CResumeThread;
- KillThread :=@CKillThread;
- ThreadSwitch :=@CThreadSwitch;
- CloseThread :=@CCloseThread;
- WaitForThreadTerminate :=@CWaitForThreadTerminate;
- ThreadSetPriority :=@CThreadSetPriority;
- ThreadGetPriority :=@CThreadGetPriority;
- GetCurrentThreadId :=@CGetCurrentThreadId;
- InitCriticalSection :=@CInitCriticalSection;
- DoneCriticalSection :=@CDoneCriticalSection;
- EnterCriticalSection :=@CEnterCriticalSection;
- TryEnterCriticalSection:=@CTryEnterCriticalSection;
- LeaveCriticalSection :=@CLeaveCriticalSection;
- InitThreadVar :=@CInitThreadVar;
- RelocateThreadVar :=@CRelocateThreadVar;
- AllocateThreadVars :=@CAllocateThreadVars;
- ReleaseThreadVars :=@CReleaseThreadVars;
- BasicEventCreate :=@intBasicEventCreate;
- BasicEventDestroy :=@intBasicEventDestroy;
- BasicEventResetEvent :=@intBasicEventResetEvent;
- BasicEventSetEvent :=@intBasicEventSetEvent;
- BasiceventWaitFor :=@intBasiceventWaitFor;
- rtlEventCreate :=@intrtlEventCreate;
- rtlEventDestroy :=@intrtlEventDestroy;
- rtlEventSetEvent :=@intrtlEventSetEvent;
- rtlEventResetEvent :=@intrtlEventResetEvent;
- rtleventWaitForTimeout :=@intrtleventWaitForTimeout;
- rtleventWaitFor :=@intrtleventWaitFor;
- // semaphores
- SemaphoreInit :=@cSemaphoreInit;
- SemaphoreDestroy :=@cSemaphoreDestroy;
- SemaphoreWait :=@cSemaphoreWait;
- SemaphorePost :=@cSemaphorePost;
- end;
- SetThreadManager(CThreadManager);
- end;
- initialization
- if ThreadingAlreadyUsed then
- begin
- writeln('Threading has been used before cthreads was initialized.');
- writeln('Make cthreads one of the first units in your uses clause.');
- runerror(211);
- end;
- SetCThreadManager;
- finalization
- end.
|