Add files via upload

Author: nislambd

App.config

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="utf-8" ?>
+<configuration>
+    <startup> 
+        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.7.2" />
+    </startup>
+  <appSettings>
+    <add key="WatchPath" value="C:\Temp"/>
+  </appSettings>
+</configuration>

FileWatcherService.cs

@@ -0,0 +1,33 @@
+using System;
+using System.Configuration;
+using System.IO;
+using System.Threading;
+
+namespace WindowsService.MultiThread
+{
+    class FileWatcherService:IServiceThread
+    {
+        private void ProcessFile(object sender, FileSystemEventArgs e)
+        {
+           Console.WriteLine($"{e.ChangeType}, {e.Name}");
+        }
+
+        public bool ServiceStarted { get; set; }
+        public void DoWork()
+        {
+            if (ServiceStarted)
+            {
+                var watchPath = ConfigurationManager.AppSettings["WatchPath"];
+                var watcher = new FileSystemWatcher(watchPath) { EnableRaisingEvents = true };
+                watcher.Filter = "*.*";
+                watcher.Created += ProcessFile;
+                watcher.Deleted += ProcessFile;
+                watcher.Changed += ProcessFile;
+            }
+            else
+            {
+                Thread.CurrentThread.Abort();
+            }
+        }
+    }
+}

IServiceThread.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace WindowsService.MultiThread
+{
+    public interface IServiceThread
+    {
+        bool ServiceStarted { get; set; }
+        void DoWork();
+    }
+}

MultiThreadService.Designer.cs

@@ -0,0 +1,48 @@
+using System;
+using System.Collections.Generic;
+using System.ComponentModel;
+using System.Data;
+using System.Diagnostics;
+using System.Linq;
+using System.ServiceProcess;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace WindowsService.MultiThread
+{
+    public partial class MultiThreadService : ServiceBase
+    {
+        private Thread[] _workerThreads;
+        private readonly IServiceThread[] _serviceThreads;
+        readonly int _numberOfThreads;
+        public MultiThreadService(IServiceThread[] serviceThreads)
+        {
+            _serviceThreads = serviceThreads;
+            _numberOfThreads = serviceThreads.Length;
+
+            InitializeComponent();
+        }
+
+        protected override void OnStart(string[] args)
+        {
+            _workerThreads = new Thread[_numberOfThreads];
+
+           for (var i = 0; i < _numberOfThreads; i++)
+            {
+                _serviceThreads[i].ServiceStarted = true;
+                _workerThreads[i] = new Thread(() => _serviceThreads[i].DoWork());
+                _workerThreads[i].Start();
+            }
+        }
+
+        protected override void OnStop()
+        {
+            for (int i = 0; i < _numberOfThreads; i++)
+            {
+                _serviceThreads[i].ServiceStarted = false;
+                _workerThreads[i].Join(500);
+            }
+        }
+    }
+}

MultiThreadService.cs

@@ -0,0 +1,57 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.ServiceProcess;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace WindowsService.MultiThread
+{
+    static class Program
+    {
+        /// <summary>
+        /// The main entry point for the application.
+        /// </summary>
+        static void Main()
+        {
+            var services = new List<IServiceThread>();
+
+            //add the services here that needs to run in each thread
+            services.Add(new FileWatcherService());
+
+            //running as service
+            if (!Environment.UserInteractive)
+            {
+                var servicesToRun = new ServiceBase[]
+                {
+                    new MultiThreadService(services.ToArray()),
+                };
+                ServiceBase.Run(servicesToRun);
+            }
+            //running as console app
+            else
+            {
+                var workerThreads = new Thread[services.Count];
+
+                for (int i = 0; i < services.Count; i++)
+                {
+                    services[i].ServiceStarted = true;
+                    workerThreads[i] = new Thread(() => services[i].DoWork());
+                    workerThreads[i].Start();
+
+                    Console.WriteLine($"{services[i].GetType().Name} running in thread {i}");
+                }
+
+                Console.WriteLine("Service is running in console mode. Press any key to quit.");
+                Console.ReadKey();
+
+                for (int i = 0; i < services.Count; i++)
+                {
+                    services[i].ServiceStarted = false;
+                    workerThreads[i].Join(500);
+                }
+            }
+        }
+    }
+}

Program.cs

@@ -0,0 +1,36 @@
+using System.Reflection;
+using System.Runtime.CompilerServices;
+using System.Runtime.InteropServices;
+
+// General Information about an assembly is controlled through the following
+// set of attributes. Change these attribute values to modify the information
+// associated with an assembly.
+[assembly: AssemblyTitle("WindowsService.MultiThread")]
+[assembly: AssemblyDescription("")]
+[assembly: AssemblyConfiguration("")]
+[assembly: AssemblyCompany("Advent Software, Inc.")]
+[assembly: AssemblyProduct("WindowsService.MultiThread")]
+[assembly: AssemblyCopyright("Copyright © Advent Software, Inc. 2019")]
+[assembly: AssemblyTrademark("")]
+[assembly: AssemblyCulture("")]
+
+// Setting ComVisible to false makes the types in this assembly not visible
+// to COM components.  If you need to access a type in this assembly from
+// COM, set the ComVisible attribute to true on that type.
+[assembly: ComVisible(false)]
+
+// The following GUID is for the ID of the typelib if this project is exposed to COM
+[assembly: Guid("2bbd35c4-1bf0-4048-9e0e-b46dcdb585ea")]
+
+// Version information for an assembly consists of the following four values:
+//
+//      Major Version
+//      Minor Version
+//      Build Number
+//      Revision
+//
+// You can specify all the values or you can default the Build and Revision Numbers
+// by using the '*' as shown below:
+// [assembly: AssemblyVersion("1.0.*")]
+[assembly: AssemblyVersion("1.0.0.0")]
+[assembly: AssemblyFileVersion("1.0.0.0")]

Properties/AssemblyInfo.cs

@@ -0,0 +1,19 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.ComponentModel;
+using System.Configuration.Install;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace WindowsService.MultiThread
+{
+    [RunInstaller(true)]
+    public partial class ServiceInstaller : System.Configuration.Install.Installer
+    {
+        public ServiceInstaller()
+        {
+            InitializeComponent();
+        }
+    }
+}