C#

1 public partial class myService : ServiceBase   
2   
3     {   
4   
5         //Initialize an instance of Timer   
6   
7         System.Threading.Timer timer;   
8   
9          public myService()   
10   
11         {               
12          InitializeComponent();    
13         }   
14   
15          protected override void OnStart(string[] args)   
16   
17         {   
18   
19             try  
20   
21             {   
22   
23                 //Service Start Time read from app.config    
24   
25                 string startTimeString = ConfigurationSettings.AppSettings           ["StartTime"].ToString();   
26   
27                 //value to pass to callback function   
28   
29                 DateTime startTime;   
30   
31                 //how long to delay in milliseconds before calling the method   
32   
33                 int millisecondsToStart = 0;   
34     
35                 if (DateTime.TryParseExact(startTimeString, "HHmm", CultureInfo.InvariantCulture, DateTimeStyles.None, out startTime))   
36   
37                 {   
38   
39                     if (DateTime.Now > startTime)   
40   
41                         startTime = startTime.AddDays(1);   
42   
43                     millisecondsToStart = (int)startTime.Subtract(DateTime.Now).TotalMilliseconds;   
44   
45                 }   
46     
47                 timer = new System.Threading.Timer(OnElapsedTime, null, millisecondsToStart, Convert.ToInt32(ConfigurationSettings.AppSettings["intervalTime"]));   
48   
49   
50             }   
51   
52             catch (Exception ex)   
53   
54             {   
55   
56                 //write exception to Event Log   
57   
58                 System.Diagnostics.EventLog.WriteEntry("error in starting my Service", ex.Message + Environment.NewLine + ex.StackTrace);   
59   
60             }   
61   
62         }   
63   
64     
65   
66         protected override void OnStop()   
67   
68         {   
69   
70             //Nothing to do here   
71   
72         }   
73   
74          private void OnElapsedTime(object source)   
75   
76         {   
77   
78             //Call the method   
79   
80             TransferData();   
81         }  

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Threading;

public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();

            new Bar1("bar1");
            new Bar2("bar2");
        }

        private void btnExec_Click(object sender, EventArgs e)
        {
            if (!DeviceBase.Run)
            {
                // Starts or continue a thread.
                DeviceBase.execAll();
            }
            else
            {
                // Some code to pause the threads
            }

            DeviceBase.Run = !DeviceBase.Run;
        }
    }

    abstract class DeviceBase
    {
        public static Dictionary<string, DeviceBase> devices = new Dictionary<string, DeviceBase>();

        private string name;
        private Thread execThread;          // The thread to simulate a device.
        protected static bool run = false;

        public DeviceBase(string name)
        {
            this.name = name;
            devices[name] = this;
            devices[name].execThread = new Thread(exec);
        }

        public string Name
        {
            get
            {
                return name;
            }
        }

        public static bool Run
        {
            get
            {
                return run;
            }
            set
            {
                run = value;
            }
        }

        // Start or continue a thread
        public static void execAll()
        {
            foreach (string device in devices.Keys)
            {
                if (devices[device].execThread.ThreadState == ThreadState.Unstarted)
                {
                    // Start all threads.
                    devices[device].execThread.Start();
                }
                else
                {
                    //Continue all paused threads.
                }
            }
        }

        public static void pauseAll()
        {
            // Pause the threads so they are not running in the CPU, but can be restarted/continued
        }

        protected virtual void exec()
        {
        }
    }

    class Bar1 : DeviceBase
    {
        public Bar1(string name) : base(name)
        {
        }

        protected override void exec()
        {
            while (run)
                Console.WriteLine(Name + " is running");
        }
    }

    class Bar2 : DeviceBase
    {
        public Bar2(string name) : base(name)
        {
        }

        protected override void exec()
        {
            while (run)
                Console.WriteLine(Name + " is running");
        }
    }