如何：使用后台线程搜索文件
BackgroundWorker 组件取代了 System.Threading 组件并向其添加了功能；但是，可以选择保留 System.Threading 组件以实现向后兼容并供将来使用。 有关详细信息，请参阅 BackgroundWorker 组件概述。
Windows 窗体使用单线程单元 (STA) 模型，因为 Windows 窗体基于固有单元线程的本机 Win32 窗口。 STA 模型意味着可以在任何线程上创建窗口，但是窗口一旦创建就不能切换线程，并且对该窗口的所有函数调用都必须发生在其创建线程上。 在 Windows 窗体之外，.NET Framework 中的类使用自由线程模型。 有关 .NET Framework 中的线程的信息，请参阅线程。
STA 模型要求控件上需要从控件的创建线程外部调用的任何方法都必须封送到（在其上执行）控件的创建线程。 为此，基类 Control 提供了多种方法（Invoke、BeginInvoke 和 EndInvoke）。 Invoke 进行同步方法调用；BeginInvoke 进行异步方法调用。
如果在控件中使用多线程处理资源密集型任务，则用户界面可以在后台线程执行资源密集型计算时保持响应。
以下示例 (DirectorySearcher) 显示了一个多线程 Windows 窗体控件，该控件使用后台线程递归搜索目录，以查找与指定搜索字符串匹配的文件，然后使用搜索结果填充列表框。 该示例说明的关键概念如下：
DirectorySearcher启动新线程来执行搜索。 线程执行ThreadProcedure方法，该方法又调用帮助程序RecurseDirectory方法来执行实际搜索并填充列表框。 但是，填充列表框需要跨线程调用，如以下两个项目符号中所述。DirectorySearcher定义了将文件添加到列表框的AddFiles方法；但是，RecurseDirectory不能直接调用AddFiles，因为AddFiles只能在创建DirectorySearcher的 STA 线程中执行。RecurseDirectory调用AddFiles的唯一方法是通过跨线程调用，即通过调用 Invoke 或 BeginInvoke 将AddFiles封送到DirectorySearcher的创建线程。RecurseDirectory使用 BeginInvoke 以便可以异步进行调用。封送方法需要函数指针或回调的等效项。 这是使用 .NET Framework 中的委托来完成的。 BeginInvoke 将委托作为参数。 因此，
DirectorySearcher定义了一个委托 (FileListDelegate)，将AddFiles绑定到其构造函数中的FileListDelegate实例，并将此委托实例传递给 BeginInvoke。DirectorySearcher还定义了一个在搜索完成时封送的事件委托。
Option Strict
Option Explicit
Imports System.IO
Imports System.Threading
Imports System.Windows.Forms
Namespace Microsoft.Samples.DirectorySearcher
' <summary>
' This class is a Windows Forms control that implements a simple directory searcher.
' You provide, through code, a search string and it will search directories on
' a background thread, populating its list box with matches.
' </summary>
Public Class DirectorySearcher
Inherits Control
' Define a special delegate that handles marshaling
' lists of file names from the background directory search
' thread to the thread that contains the list box.
Delegate Sub FileListDelegate(files() As String, startIndex As Integer, count As Integer)
Private _listBox As ListBox
Private _searchCriteria As String
Private _searching As Boolean
Private _deferSearch As Boolean
Private _searchThread As Thread
Private _fileListDelegate As FileListDelegate
Private _onSearchComplete As EventHandler
Public Sub New()
_listBox = New ListBox()
_listBox.Dock = DockStyle.Fill
Controls.Add(_listBox)
_fileListDelegate = New FileListDelegate(AddressOf AddFiles)
_onSearchComplete = New EventHandler(AddressOf OnSearchComplete)
End Sub
Public Property SearchCriteria() As String
Get
Return _searchCriteria
End Get
Set
' If currently searching, abort
' the search and restart it after
' setting the new criteria.
'
Dim wasSearching As Boolean = Searching
If wasSearching Then
StopSearch()
End If
_listBox.Items.Clear()
_searchCriteria = value
If wasSearching Then
BeginSearch()
End If
End Set
End Property
Public ReadOnly Property Searching() As Boolean
Get
Return _searching
End Get
End Property
Public Event SearchComplete As EventHandler
' <summary>
' This method is called from the background thread. It is called through
' a BeginInvoke call so that it is always marshaled to the thread that
' owns the list box control.
' </summary>
' <param name="files"></param>
' <param name="startIndex"></param>
' <param name="count"></param>
Private Sub AddFiles(files() As String, startIndex As Integer, count As Integer)
While count > 0
count -= 1
_listBox.Items.Add(files((startIndex + count)))
End While
End Sub
Public Sub BeginSearch()
' Create the search thread, which
' will begin the search.
' If already searching, do nothing.
'
If Searching Then
Return
End If
' Start the search if the handle has
' been created. Otherwise, defer it until the
' handle has been created.
If IsHandleCreated Then
_searchThread = New Thread(New ThreadStart(AddressOf ThreadProcedure))
_searching = True
_searchThread.Start()
Else
_deferSearch = True
End If
End Sub
Protected Overrides Sub OnHandleDestroyed(e As EventArgs)
' If the handle is being destroyed and you are not
' recreating it, then abort the search.
If Not RecreatingHandle Then
StopSearch()
End If
MyBase.OnHandleDestroyed(e)
End Sub
Protected Overrides Sub OnHandleCreated(e As EventArgs)
MyBase.OnHandleCreated(e)
If _deferSearch Then
_deferSearch = False
BeginSearch()
End If
End Sub
' <summary>
' This method is called by the background thread when it has
' finished the search.
' </summary>
' <param name="sender"></param>
' <param name="e"></param>
Private Sub OnSearchComplete(sender As Object, e As EventArgs)
RaiseEvent SearchComplete(sender, e)
End Sub
Public Sub StopSearch()
If Not _searching Then
Return
End If
If _searchThread.IsAlive Then
_searchThread.Abort()
_searchThread.Join()
End If
_searchThread = Nothing
_searching = False
End Sub
' <summary>
' Recurses the given path, adding all files on that path to
' the list box. After it finishes with the files, it
' calls itself once for each directory on the path.
' </summary>
' <param name="searchPath"></param>
Private Sub RecurseDirectory(searchPath As String)
' Split searchPath into a directory and a wildcard specification.
'
Dim directoryPath As String = Path.GetDirectoryName(searchPath)
Dim search As String = Path.GetFileName(searchPath)
' If a directory or search criteria are not specified, then return.
'
If directoryPath Is Nothing Or search Is Nothing Then
Return
End If
Dim files() As String
' File systems like NTFS that have
' access permissions might result in exceptions
' when looking into directories without permission.
' Catch those exceptions and return.
Try
files = Directory.GetFiles(directoryPath, search)
Catch e As UnauthorizedAccessException
Return
Catch e As DirectoryNotFoundException
Return
End Try
' Perform a BeginInvoke call to the list box
' in order to marshal to the correct thread. It is not
' very efficient to perform this marshal once for every
' file, so batch up multiple file calls into one
' marshal invocation.
Dim startingIndex As Integer = 0
While startingIndex < files.Length
' Batch up 20 files at once, unless at the
' end.
'
Dim count As Integer = 20
If count + startingIndex >= files.Length Then
count = files.Length - startingIndex
End If
' Begin the cross-thread call. Because you are passing
' immutable objects into this invoke method, you do not have to
' wait for it to finish. If these were complex objects, you would
' have to either create new instances of them or
' wait for the thread to process this invoke before modifying
' the objects.
Dim r As IAsyncResult = BeginInvoke(_fileListDelegate, New Object() {files, startingIndex, count})
startingIndex += count
End While
' Now that you have finished the files in this directory, recurse
' for each subdirectory.
Dim directories As String() = Directory.GetDirectories(directoryPath)
Dim d As String
For Each d In directories
RecurseDirectory(Path.Combine(d, search))
Next d
End Sub
'/ <summary>
'/ This is the actual thread procedure. This method runs in a background
'/ thread to scan directories. When finished, it simply exits.
'/ </summary>
Private Sub ThreadProcedure()
' Get the search string. Individual
' field assigns are atomic in .NET, so you do not
' need to use any thread synchronization to grab
' the string value here.
Try
Dim localSearch As String = SearchCriteria
' Now, search the file system.
'
RecurseDirectory(localSearch)
Finally
' You are done with the search, so update.
'
_searching = False
' Raise an event that notifies the user that
' the search has terminated.
' You do not have to do this through a marshaled call, but
' marshaling is recommended for the following reason:
' Users of this control do not know that it is
' multithreaded, so they expect its events to
' come back on the same thread as the control.
BeginInvoke(_onSearchComplete, New Object() {Me, EventArgs.Empty})
End Try
End Sub
End Class
End Namespace
namespace Microsoft.Samples.DirectorySearcher
{
using System;
using System.IO;
using System.Threading;
using System.Windows.Forms;
/// <summary>
/// This class is a Windows Forms control that implements a simple directory searcher.
/// You provide, through code, a search string and it will search directories on
/// a background thread, populating its list box with matches.
/// </summary>
public class DirectorySearcher : Control
{
// Define a special delegate that handles marshaling
// lists of file names from the background directory search
// thread to the thread that contains the list box.
private delegate void FileListDelegate(string[] files, int startIndex, int count);
private ListBox listBox;
private string searchCriteria;
private bool searching;
private bool deferSearch;
private Thread searchThread;
private FileListDelegate fileListDelegate;
private EventHandler onSearchComplete;
public DirectorySearcher()
{
listBox = new ListBox();
listBox.Dock = DockStyle.Fill;
Controls.Add(listBox);
fileListDelegate = new FileListDelegate(AddFiles);
onSearchComplete = new EventHandler(OnSearchComplete);
}
public string SearchCriteria
{
get
{
return searchCriteria;
}
set
{
// If currently searching, abort
// the search and restart it after
// setting the new criteria.
//
bool wasSearching = Searching;
if (wasSearching)
{
StopSearch();
}
listBox.Items.Clear();
searchCriteria = value;
if (wasSearching)
{
BeginSearch();
}
}
}
public bool Searching
{
get
{
return searching;
}
}
public event EventHandler SearchComplete;
/// <summary>
/// This method is called from the background thread. It is called through
/// a BeginInvoke call so that it is always marshaled to the thread that
/// owns the list box control.
/// </summary>
/// <param name="files"></param>
/// <param name="startIndex"></param>
/// <param name="count"></param>
private void AddFiles(string[] files, int startIndex, int count)
{
while(count-- > 0)
{
listBox.Items.Add(files[startIndex + count]);
}
}
public void BeginSearch()
{
// Create the search thread, which
// will begin the search.
// If already searching, do nothing.
//
if (Searching)
{
return;
}
// Start the search if the handle has
// been created. Otherwise, defer it until the
// handle has been created.
if (IsHandleCreated)
{
searchThread = new Thread(new ThreadStart(ThreadProcedure));
searching = true;
searchThread.Start();
}
else
{
deferSearch = true;
}
}
protected override void OnHandleDestroyed(EventArgs e)
{
// If the handle is being destroyed and you are not
// recreating it, then abort the search.
if (!RecreatingHandle)
{
StopSearch();
}
base.OnHandleDestroyed(e);
}
protected override void OnHandleCreated(EventArgs e)
{
base.OnHandleCreated(e);
if (deferSearch)
{
deferSearch = false;
BeginSearch();
}
}
/// <summary>
/// This method is called by the background thread when it has finished
/// the search.
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void OnSearchComplete(object sender, EventArgs e)
{
if (SearchComplete != null)
{
SearchComplete(sender, e);
}
}
public void StopSearch()
{
if (!searching)
{
return;
}
if (searchThread.IsAlive)
{
searchThread.Abort();
searchThread.Join();
}
searchThread = null;
searching = false;
}
/// <summary>
/// Recurses the given path, adding all files on that path to
/// the list box. After it finishes with the files, it
/// calls itself once for each directory on the path.
/// </summary>
/// <param name="searchPath"></param>
private void RecurseDirectory(string searchPath)
{
// Split searchPath into a directory and a wildcard specification.
//
string directory = Path.GetDirectoryName(searchPath);
string search = Path.GetFileName(searchPath);
// If a directory or search criteria are not specified, then return.
//
if (directory == null || search == null)
{
return;
}
string[] files;
// File systems like NTFS that have
// access permissions might result in exceptions
// when looking into directories without permission.
// Catch those exceptions and return.
try
{
files = Directory.GetFiles(directory, search);
}
catch(UnauthorizedAccessException)
{
return;
}
catch(DirectoryNotFoundException)
{
return;
}
// Perform a BeginInvoke call to the list box
// in order to marshal to the correct thread. It is not
// very efficient to perform this marshal once for every
// file, so batch up multiple file calls into one
// marshal invocation.
int startingIndex = 0;
while(startingIndex < files.Length)
{
// Batch up 20 files at once, unless at the
// end.
//
int count = 20;
if (count + startingIndex >= files.Length)
{
count = files.Length - startingIndex;
}
// Begin the cross-thread call. Because you are passing
// immutable objects into this invoke method, you do not have to
// wait for it to finish. If these were complex objects, you would
// have to either create new instances of them or
// wait for the thread to process this invoke before modifying
// the objects.
IAsyncResult r = BeginInvoke(fileListDelegate, new object[] {files, startingIndex, count});
startingIndex += count;
}
// Now that you have finished the files in this directory, recurse for
// each subdirectory.
string[] directories = Directory.GetDirectories(directory);
foreach(string d in directories)
{
RecurseDirectory(Path.Combine(d, search));
}
}
/// <summary>
/// This is the actual thread procedure. This method runs in a background
/// thread to scan directories. When finished, it simply exits.
/// </summary>
private void ThreadProcedure()
{
// Get the search string. Individual
// field assigns are atomic in .NET, so you do not
// need to use any thread synchronization to grab
// the string value here.
try
{
string localSearch = SearchCriteria;
// Now, search the file system.
//
RecurseDirectory(localSearch);
}
finally
{
// You are done with the search, so update.
//
searching = false;
// Raise an event that notifies the user that
// the search has terminated.
// You do not have to do this through a marshaled call, but
// marshaling is recommended for the following reason:
// Users of this control do not know that it is
// multithreaded, so they expect its events to
// come back on the same thread as the control.
BeginInvoke(onSearchComplete, new object[] {this, EventArgs.Empty});
}
}
}
}
在窗体上使用多线程控件
以下示例显示了如何在窗体上使用多线程 DirectorySearcher 控件。
Option Explicit
Option Strict
Imports System.Collections
Imports System.ComponentModel
Imports System.Data
Imports System.Drawing
Imports System.Windows.Forms
Imports Microsoft.Samples.DirectorySearcher
Namespace SampleUsage
' <summary>
' Summary description for Form1.
' </summary>
Public Class Form1
Inherits System.Windows.Forms.Form
Private WithEvents directorySearcher As DirectorySearcher
Private searchText As System.Windows.Forms.TextBox
Private searchLabel As System.Windows.Forms.Label
Private WithEvents searchButton As System.Windows.Forms.Button
Public Sub New()
'
' Required for Windows Forms designer support.
'
InitializeComponent()
'
' Add any constructor code after InitializeComponent call here.
'
End Sub
#Region "Windows Form Designer generated code"
' <summary>
' Required method for designer support. Do not modify
' the contents of this method with the code editor.
' </summary>
Private Sub InitializeComponent()
Me.directorySearcher = New Microsoft.Samples.DirectorySearcher.DirectorySearcher()
Me.searchButton = New System.Windows.Forms.Button()
Me.searchText = New System.Windows.Forms.TextBox()
Me.searchLabel = New System.Windows.Forms.Label()
Me.directorySearcher.Anchor = System.Windows.Forms.AnchorStyles.Top Or System.Windows.Forms.AnchorStyles.Bottom Or System.Windows.Forms.AnchorStyles.Left Or System.Windows.Forms.AnchorStyles.Right
Me.directorySearcher.Location = New System.Drawing.Point(8, 72)
Me.directorySearcher.SearchCriteria = Nothing
Me.directorySearcher.Size = New System.Drawing.Size(271, 173)
Me.directorySearcher.TabIndex = 2
Me.searchButton.Location = New System.Drawing.Point(8, 16)
Me.searchButton.Size = New System.Drawing.Size(88, 40)
Me.searchButton.TabIndex = 0
Me.searchButton.Text = "&Search"
Me.searchText.Anchor = System.Windows.Forms.AnchorStyles.Top Or System.Windows.Forms.AnchorStyles.Left Or System.Windows.Forms.AnchorStyles.Right
Me.searchText.Location = New System.Drawing.Point(104, 24)
Me.searchText.Size = New System.Drawing.Size(175, 20)
Me.searchText.TabIndex = 1
Me.searchText.Text = "c:\*.cs"
Me.searchLabel.ForeColor = System.Drawing.Color.Red
Me.searchLabel.Location = New System.Drawing.Point(104, 48)
Me.searchLabel.Size = New System.Drawing.Size(176, 16)
Me.searchLabel.TabIndex = 3
Me.ClientSize = New System.Drawing.Size(291, 264)
Me.Controls.AddRange(New System.Windows.Forms.Control() {Me.searchLabel, Me.directorySearcher, Me.searchText, Me.searchButton})
Me.Text = "Search Directories"
End Sub
#End Region
' <summary>
' The main entry point for the application.
' </summary>
<STAThread()> _
Shared Sub Main()
Application.Run(New Form1())
End Sub
Private Sub searchButton_Click(sender As Object, e As System.EventArgs) Handles searchButton.Click
directorySearcher.SearchCriteria = searchText.Text
searchLabel.Text = "Searching..."
directorySearcher.BeginSearch()
End Sub
Private Sub directorySearcher_SearchComplete(sender As Object, e As System.EventArgs) Handles directorySearcher.SearchComplete
searchLabel.Text = String.Empty
End Sub
End Class
End Namespace
namespace SampleUsage
{
using System;
using System.Collections;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Windows.Forms;
using Microsoft.Samples.DirectorySearcher;
/// <summary>
/// Summary description for Form1.
/// </summary>
public class Form1 : System.Windows.Forms.Form
{
private DirectorySearcher directorySearcher;
private System.Windows.Forms.TextBox searchText;
private System.Windows.Forms.Label searchLabel;
private System.Windows.Forms.Button searchButton;
public Form1()
{
//
// Required for Windows Forms designer support.
//
InitializeComponent();
//
// Add any constructor code after InitializeComponent call here.
//
}
#region Windows Form Designer generated code
/// <summary>
/// Required method for designer support. Do not modify
/// the contents of this method with the code editor.
/// </summary>
private void InitializeComponent()
{
this.directorySearcher = new Microsoft.Samples.DirectorySearcher.DirectorySearcher();
this.searchButton = new System.Windows.Forms.Button();
this.searchText = new System.Windows.Forms.TextBox();
this.searchLabel = new System.Windows.Forms.Label();
this.directorySearcher.Anchor = (((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Bottom)
| System.Windows.Forms.AnchorStyles.Left)
| System.Windows.Forms.AnchorStyles.Right);
this.directorySearcher.Location = new System.Drawing.Point(8, 72);
this.directorySearcher.SearchCriteria = null;
this.directorySearcher.Size = new System.Drawing.Size(271, 173);
this.directorySearcher.TabIndex = 2;
this.directorySearcher.SearchComplete += new System.EventHandler(this.directorySearcher_SearchComplete);
this.searchButton.Location = new System.Drawing.Point(8, 16);
this.searchButton.Size = new System.Drawing.Size(88, 40);
this.searchButton.TabIndex = 0;
this.searchButton.Text = "&Search";
this.searchButton.Click += new System.EventHandler(this.searchButton_Click);
this.searchText.Anchor = ((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Left)
| System.Windows.Forms.AnchorStyles.Right);
this.searchText.Location = new System.Drawing.Point(104, 24);
this.searchText.Size = new System.Drawing.Size(175, 20);
this.searchText.TabIndex = 1;
this.searchText.Text = "c:\\*.cs";
this.searchLabel.ForeColor = System.Drawing.Color.Red;
this.searchLabel.Location = new System.Drawing.Point(104, 48);
this.searchLabel.Size = new System.Drawing.Size(176, 16);
this.searchLabel.TabIndex = 3;
this.ClientSize = new System.Drawing.Size(291, 264);
this.Controls.AddRange(new System.Windows.Forms.Control[] {this.searchLabel,
this.directorySearcher,
this.searchText,
this.searchButton});
this.Text = "Search Directories";
}
#endregion
/// <summary>
/// The main entry point for the application.
/// </summary>
[STAThread]
static void Main()
{
Application.Run(new Form1());
}
private void searchButton_Click(object sender, System.EventArgs e)
{
directorySearcher.SearchCriteria = searchText.Text;
searchLabel.Text = "Searching...";
directorySearcher.BeginSearch();
}
private void directorySearcher_SearchComplete(object sender, System.EventArgs e)
{
searchLabel.Text = string.Empty;
}
}
}
