diff options
Diffstat (limited to 'mcs/class/corlib/System.Threading/Thread.cs')
| -rwxr-xr-x | mcs/class/corlib/System.Threading/Thread.cs | 438 |
1 files changed, 0 insertions, 438 deletions
diff --git a/mcs/class/corlib/System.Threading/Thread.cs b/mcs/class/corlib/System.Threading/Thread.cs deleted file mode 100755 index 9288a8b4562..00000000000 --- a/mcs/class/corlib/System.Threading/Thread.cs +++ /dev/null @@ -1,438 +0,0 @@ -// -// System.Threading.Thread.cs -// -// Author: -// Dick Porter (dick@ximian.com) -// -// (C) Ximian, Inc. http://www.ximian.com -// - -using System.Runtime.Remoting.Contexts; -using System.Security.Principal; -using System.Globalization; -using System.Runtime.CompilerServices; -using System.Collections; - -namespace System.Threading -{ - public sealed class Thread - { - private bool threadpool_thread = false; - private CultureInfo current_culture; - - [MonoTODO] - public static Context CurrentContext { - get { - // FIXME - - // System.Runtime.Remoting.Context not - // yet implemented - return(null); - } - } - - [MonoTODO] - public static IPrincipal CurrentPrincipal { - get { - // FIXME - - // System.Security.Principal.IPrincipal - // not yet implemented - return(null); - } - - set { - } - } - - // Looks up the object associated with the current thread - [MethodImplAttribute(MethodImplOptions.InternalCall)] - private extern static Thread CurrentThread_internal(); - - public static Thread CurrentThread { - get { - return(CurrentThread_internal()); - } - } - - // Looks up the slot hash for the current thread - [MethodImplAttribute(MethodImplOptions.InternalCall)] - private extern static Hashtable SlotHash_lookup(); - - // Stores the slot hash for the current thread - [MethodImplAttribute(MethodImplOptions.InternalCall)] - private extern static void SlotHash_store(Hashtable slothash); - - private static Hashtable GetTLSSlotHash() { - Hashtable slothash=SlotHash_lookup(); - if(slothash==null) { - // Not synchronised, because this is - // thread specific anyway. - slothash=new Hashtable(); - SlotHash_store(slothash); - } - - return(slothash); - } - - public static LocalDataStoreSlot AllocateDataSlot() { - LocalDataStoreSlot slot = new LocalDataStoreSlot(); - - return(slot); - } - - // Stores a hash keyed by strings of LocalDataStoreSlot objects - static Hashtable datastorehash = Hashtable.Synchronized(new Hashtable()); - - public static LocalDataStoreSlot AllocateNamedDataSlot(string name) { - LocalDataStoreSlot slot = (LocalDataStoreSlot)datastorehash[name]; - if(slot!=null) { - // This exception isnt documented (of - // course) but .net throws it - throw new ArgumentException("Named data slot already added"); - } - - slot = new LocalDataStoreSlot(); - - datastorehash.Add(name, slot); - - return(slot); - } - - public static void FreeNamedDataSlot(string name) { - LocalDataStoreSlot slot=(LocalDataStoreSlot)datastorehash[name]; - - if(slot!=null) { - datastorehash.Remove(slot); - } - } - - public static object GetData(LocalDataStoreSlot slot) { - Hashtable slothash=GetTLSSlotHash(); - return(slothash[slot]); - } - - [MonoTODO] - public static AppDomain GetDomain() { - // FIXME - return(null); - } - - [MonoTODO] - public static int GetDomainID() { - // FIXME - return(0); - } - - public static LocalDataStoreSlot GetNamedDataSlot(string name) { - LocalDataStoreSlot slot=(LocalDataStoreSlot)datastorehash[name]; - - if(slot==null) { - slot=AllocateNamedDataSlot(name); - } - - return(slot); - } - - [MonoTODO] - public static void ResetAbort() { - // FIXME - } - - public static void SetData(LocalDataStoreSlot slot, - object data) { - Hashtable slothash=GetTLSSlotHash(); - - if(slothash[slot]!=null) { - slothash.Remove(slot); - } - - slothash.Add(slot, data); - } - - [MethodImplAttribute(MethodImplOptions.InternalCall)] - private extern static void Sleep_internal(int ms); - - public static void Sleep(int millisecondsTimeout) { - if(millisecondsTimeout<0) { - throw new ArgumentException("Negative timeout"); - } - Thread thread=CurrentThread; - - thread.set_state(ThreadState.WaitSleepJoin); - - Sleep_internal(millisecondsTimeout); - thread.clr_state(ThreadState.WaitSleepJoin); - } - - public static void Sleep(TimeSpan timeout) { - // LAMESPEC: says to throw ArgumentException too - if(timeout.Milliseconds < 0 || timeout.Milliseconds > Int32.MaxValue) { - throw new ArgumentOutOfRangeException("Timeout out of range"); - } - - Thread thread=CurrentThread; - - thread.set_state(ThreadState.WaitSleepJoin); - Sleep_internal(timeout.Milliseconds); - thread.clr_state(ThreadState.WaitSleepJoin); - } - - // stores a thread handle - private IntPtr system_thread_handle; - - // Returns the system thread handle - [MethodImplAttribute(MethodImplOptions.InternalCall)] - private extern IntPtr Thread_internal(ThreadStart start); - - public Thread(ThreadStart start) { - if(start==null) { - throw new ArgumentNullException("Null ThreadStart"); - } - - // This is a two-stage thread launch. Thread_internal - // creates the new thread, but blocks it until - // Start() is called later. - system_thread_handle=Thread_internal(start); - - // Should throw an exception here if - // Thread_internal returns NULL - } - - [MonoTODO] - public ApartmentState ApartmentState { - get { - // FIXME - return(ApartmentState.Unknown); - } - - set { - } - } - - [MonoTODO] - public CultureInfo CurrentCulture { - get { - if (current_culture == null) - current_culture = new CultureInfo (""); - return current_culture; - } - - set { - current_culture = value; - } - } - - [MonoTODO] - public CultureInfo CurrentUICulture { - get { - // FIXME - return(null); - } - - set { - } - } - - public bool IsThreadPoolThread { - get { - return IsThreadPoolThreadInternal; - } - } - - internal bool IsThreadPoolThreadInternal { - get { - return threadpool_thread; - } - set { - threadpool_thread = value; - } - } - - public bool IsAlive { - get { - // LAMESPEC: is a Stopped or Suspended - // thread dead? - ThreadState curstate=state; - - if((curstate & ThreadState.Aborted) != 0 || - (curstate & ThreadState.AbortRequested) != 0 || - (curstate & ThreadState.Unstarted) != 0) { - return(false); - } else { - return(true); - } - } - } - - public bool IsBackground { - get { - if((state & ThreadState.Background) != 0) { - return(true); - } else { - return(false); - } - } - - set { - if(value==true) { - set_state(ThreadState.Background); - } else { - clr_state(ThreadState.Background); - } - } - } - - private string thread_name=null; - - public string Name { - get { - return(thread_name); - } - - set { - thread_name=value; - } - } - - [MonoTODO] - public ThreadPriority Priority { - get { - // FIXME - return(ThreadPriority.Lowest); - } - - set { - } - } - - private ThreadState state=ThreadState.Unstarted; - - public ThreadState ThreadState { - get { - return(state); - } - } - - [MonoTODO] - public void Abort() { - // FIXME - } - - [MonoTODO] - public void Abort(object stateInfo) { - // FIXME - } - - [MonoTODO] - public void Interrupt() { - // FIXME - } - - // The current thread joins with 'this'. Set ms to 0 to block - // until this actually exits. - [MethodImplAttribute(MethodImplOptions.InternalCall)] - private extern bool Join_internal(int ms, IntPtr handle); - - public void Join() { - if((state & ThreadState.Unstarted) != 0) { - throw new ThreadStateException("Thread has not been started"); - } - - Thread thread=CurrentThread; - - thread.set_state(ThreadState.WaitSleepJoin); - Join_internal(Timeout.Infinite, system_thread_handle); - thread.clr_state(ThreadState.WaitSleepJoin); - } - - public bool Join(int millisecondsTimeout) { - if(millisecondsTimeout<0) { - throw new ArgumentException("Timeout less than zero"); - } - if((state & ThreadState.Unstarted) != 0) { - throw new ThreadStateException("Thread has not been started"); - } - - Thread thread=CurrentThread; - - thread.set_state(ThreadState.WaitSleepJoin); - bool ret=Join_internal(millisecondsTimeout, - system_thread_handle); - thread.clr_state(ThreadState.WaitSleepJoin); - - return(ret); - } - - public bool Join(TimeSpan timeout) { - // LAMESPEC: says to throw ArgumentException too - if(timeout.Milliseconds < 0 || timeout.Milliseconds > Int32.MaxValue) { - throw new ArgumentOutOfRangeException("timeout out of range"); - } - if((state & ThreadState.Unstarted) != 0) { - throw new ThreadStateException("Thread has not been started"); - } - - Thread thread=CurrentThread; - - thread.set_state(ThreadState.WaitSleepJoin); - bool ret=Join_internal(timeout.Milliseconds, - system_thread_handle); - thread.clr_state(ThreadState.WaitSleepJoin); - - return(ret); - } - - [MonoTODO] - public void Resume() { - // FIXME - } - - // Launches the thread - [MethodImplAttribute(MethodImplOptions.InternalCall)] - private extern void Start_internal(IntPtr handle); - - public void Start() { - if((state & ThreadState.Unstarted) == 0) { - throw new ThreadStateException("Thread has already been started"); - } - - // Mark the thread state as Running (which is - // all bits cleared). Therefore just remove - // the Unstarted bit - clr_state(ThreadState.Unstarted); - - // Launch this thread - Start_internal(system_thread_handle); - } - - [MonoTODO] - public void Suspend() { - if((state & ThreadState.Unstarted) != 0 || !IsAlive) { - throw new ThreadStateException("Thread has not been started, or is dead"); - } - - set_state(ThreadState.SuspendRequested); - // FIXME - somehow let the interpreter know that - // this thread should now suspend - } - - // Closes the system thread handle - [MethodImplAttribute(MethodImplOptions.InternalCall)] - private extern void Thread_free_internal(IntPtr handle); - - ~Thread() { - // Free up the handle - Thread_free_internal(system_thread_handle); - } - - private void set_state(ThreadState set) { - lock(this) { - state |= set; - } - } - private void clr_state(ThreadState clr) { - lock(this) { - state &= ~clr; - } - } - } -} |