扫一扫
分享文章到微信
扫一扫
关注官方公众号
至顶头条
作者:佚名 来源:Microsoft 2007年10月15日
关键字:
.NET Framework的一个很重要的特性是,可以在不使用第三方工具或不支持的Visual Basic技巧情况下,使用Visual Basic创建多线程应用程序。.NET Framework的多线程支持是由System.Threading名称空间中的类和接口提供的,因此所有的.NET语言都能够以相同的方式创建和处理线程。System.Threading.Thread是一个核心类,提供了对创建和控制线程的支持。要创建一个线程,你可以创建一个新的System.Threading.Thread对象,将构造函数传递给ThreadStart代理。这个代理提供了这个线程开始执行的方法。当你准备启动这个新的线程时,可以调用Thread.Start() (请参阅清单1)。
当你开始创建多线程应用程序时,你很快就会认识到需要控制对共享资源的访问,如共享的类变量。.NET Framework还包括几个类和数据类型,你可以使用它们对两个线程执行的动作进行同步。
在最简单的情况中,你由一个需要从不同的线程中进行更新的共享变量。要这样做,你可以使用System.Threading.Interlocked类。例如,你可以通过编写Interlocked.Increment(num)或Interlocked.Decrement(num)分别使名为num的共享变量递增或递减。你还可以使用Interlocked将变量设为某一特定值,或检查两个变量是否相等。除了这种简单情况以外,你可以使用.NET Framework类来执行更复杂的线程同步,如事件和互斥体的同步-所有都来自于.NET Framework内部,而无须使用Win32 API。
Imports System.IO 'The namespace System.Threading 'contains the Thread class Imports System.Threading Module Module1 Private count As Long Sub Main() 'Create the ThreadStart delegate Dim tStart As ThreadStart = New _ ThreadStart(AddressOf StartCounting) 'Create the thread Dim t1 As Thread = New Thread(tStart) Console.WriteLine("Enter q to quit") t1.Start() 'start the thread While (Console.Read() <> asc("q")) 'repeat the loop until the user enters q End While t1.Stop() 'tell thread to stop processing t1.Join() 'wait until the thread finishes End Sub Sub StartCounting() Do 'use Interlocked.Increment in case 'another thread is accessing the same variable Interlocked.Increment(count) Console.WriteLine( _ "After incrementing count is : {0}", count) Thread.Sleep(200) Loop End Sub End Module |
你创建了一个新线程,将它传递给一个ThreadStart代理。然后调用Thread.Start()启动这个线程。你可以通过调用Thread.Stop()来中止这个线程,然后调用Thread.Join()等待它完成关闭操作。一个线程可以使用System.Threading.Interlocked来使变量递增或递减。
此外,.NET Framework提供了一个方便的机制来对工作排队,并将起分配给线程池中的某个线程。在处理多个并发工作项目或工作请求的服务器应用程序中,这非常有用。例如,对于等待输入文件,然后将它们导入到数据库中去的应用程序,可能会对每个输入文件进行排队,以在线程池中的某个单独的线程上进行处理。System.Threading.ThreadPool类允许你使用共享的QueueUserWorkItem方法对工作进行排队。以前要这样做,你必须得创建和管理自己的线程池。你又需要在基础设施工作而不是在解决商务问题上花大量的时间和精力。
文件系统监控
我曾经遇到过一些应用程序,需要等待和处理某个特定目录中的文件-例如,将数据从文件导入到数据库中去的应用程序。数据文件可以从某个大型机上下载,或者被转移到某个输入目录中,该应用程序将它们导入到数据库中。你不用经常地轮询该目录检查是否有新文件,可以等待生成新文件的通知。你可以在Visual Basic 6.0中使用Win32 API来做到这一点,而在Visual Basic .NET中你可以使用.NET Framework类来做这项工作。但是在.NET中实施文件监控与在.NET中完成其他工作的方法更加一致,因此学习曲线是最小的。
你可以使用System.IO.FileSystemWatcher .NET类对文件系统进行监视。它提供了一些属性,允许你设置监控的路径,指定是对文件还是子目录层次的变化感兴趣。System.IO.FileSystemWatcher还允许你指定需要监控的文件名和文件类型(例如,*.xml是指监控所有XML文件的变化)。最后,你可以指定感兴趣的变化类型-例如,只对新建文件,文件属性的变化或文件大小的变化(请参阅清单2)感兴趣。
在你设置了监控内容后,你需要钩住用于感兴趣的各种事件的事件处理程序。FileSystemWatcher事件有Changed、Created、Deleted、Error和Renamed。要处理某个事件,首先你需要编写一个与FileSystemEventHandler代理相同声明的事件处理程序,然后将这个处理程序添加到FileSystemWatcher类中。这个基于代理的体系结构允许你为同一个事件添加多个处理程序,或者对于多个事件使用同一个处理程序-而你不能使用Visual Basic 6.0做到这一点。
'System.IO contains the 'file monitoring classes and types Imports System.IO Module Module1 Sub Main() 'FileSystemWatcher does the real work Dim fw As New FileSystemWatcher() 'WaitForChangedResult is what you 'get back when a change occurs Dim result As WaitForChangedResult 'set the path to monitor fw.Path = "C:\WINNT\" 'tell it whether to watch files or directories fw.Target = WatcherTarget.File 'tell it whether to include subdirs fw.IncludeSubdirectories = False 'hook up handlers AddHandler fw.Created, _ New FileSystemEventHandler(AddressOf OnFileNotify) 'enable the watcher fw.Enabled = True Do Console.WriteLine("Beginning to monitor") 'this is where we actually wait 'waiting blocks execution for the specified timeout result = fw.WaitForChanged(WatcherChangeTypes.All, 60000) Console.WriteLine("Hit Enter to continue q to quit") Loop While (Console.ReadLine <> "q") End Sub 'This is the delegate that gets 'called when a file is created Public Sub OnFileNotify(ByVal source As Object, _ ByVal e As FileSystemEventArgs) Console.WriteLine( _ "Notification received for file {0}, change type is {1}", _ e.FullPath, e.ChangeType) End Sub End Module |
清单2. 使用FileSystemWatcher监控某个文件夹是否有新文件。
你可以创建一个FileSystemWatcher,然后设置它的属性。你可以使用AddHandler将FileSystemEventHandler代理与各种FileSystemWatcher事件关联起来,如Created。然后你就可以启用FileSystemWatcher,然后调用WaitForChanged。该调用将在变化发生或达到指定的超时时返回。
如果您非常迫切的想了解IT领域最新产品与技术信息,那么订阅至顶网技术邮件将是您的最佳途径之一。
现场直击|2021世界人工智能大会
直击5G创新地带,就在2021MWC上海
5G已至 转型当时——服务提供商如何把握转型的绝佳时机
寻找自己的Flag
华为开发者大会2020(Cloud)- 科技行者