C#

private void ReceiveCallback(IAsyncResult ar)
        {
            try
            {
                if (null == ar)
                    return;

                // Retrieve the state object and the client socket 
                // from the asynchronous state object.
                StateObject state = (StateObject)ar.AsyncState;
                Socket client = state.workSocket;

                if (null == state)
                    return;

                // Read data from the remote device.
                int bytesRead = client.EndReceive(ar);

                if (bytesRead > 0)
                {
                    //把接收到的数据写入流中
                    ms.Write(state.buffer, 0, bytesRead);
                    state.sb.Append(Encoding.UTF8.GetString(state.buffer, 0, bytesRead));
                    if (!state.sb.ToString().EndsWith("\r\n\r\n"))
                    {
                        client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
                            new AsyncCallback(ReceiveCallback), state);
                    }
                    else
                    {
                        int index = state.sb.ToString().IndexOf("\r\n\r\n", System.StringComparison.Ordinal);
                        int lastclr = state.sb.ToString().LastIndexOf("\r\n", index);
                        string strhex = state.sb.ToString().Substring(lastclr + 2, index - lastclr -2);
                        Int32 hex;
                        if (Int32.TryParse(strhex, System.Globalization.NumberStyles.AllowHexSpecifier, null,
                            out hex))
                        {
                            // All the data has arrived; put it in response.
                            if (state.sb.Length > 1)
                            {
                                Response = state.sb.ToString();
                            }
                            // Signal that all bytes have been received.
                            receiveDone.Set();
                        }
                        else
                        {
                            //client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,new AsyncCallback(ReceiveCallback), state);
                            client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
                            ReceiveCallback, state);
                        }
                    }
                    // Get the rest of the data.
                }
                else
                {
                    // All the data has arrived; put it in response.
                    if (state.sb.Length > 1)
                    {
                        Response = state.sb.ToString();
                    }
                    // Signal that all bytes have been received.
                    receiveDone.Set();
                }
            }
            catch (Exception e)
            {
                throw new Exception("ReceiveCallback Error: " + e);
            }
        }

for (int nIndex = 0; nIndex < value; nIndex++)
                    {
                        // check if thread not created or not suspended
                        if (threadsRun[nIndex] == null && ThreadsRunning)
                        {
                            // create new thread
                            threadsRun[nIndex] = new Thread(new ThreadStart(delegate() { ThreadScraper(); }));
                            // set thread name equal to its index
                            threadsRun[nIndex].Name = nIndex.ToString();
                            // start thread working function
                            threadsRun[nIndex].Start();
                        }
                        else
                        {
                            Console.Write("");
                        }
                    }

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace RmsBottleByLocation
{
    public partial class frmMain : Form
    {
        public frmMain()
        {
            InitializeComponent();
        }

        private void btnCancel_Click(object sender, EventArgs e)
        {
            this.Close();
            System.Environment.Exit(0);
        }

        private void btnSearch_Click(object sender, EventArgs e)
        {
            lblResults.Text = String.Empty;

            grdResults.DataSource = null;
            grdResults.Rows.Clear();
            grdResults.Refresh();

            string keyword = txtKeyword.Text.Trim();
            int minimumKeywordLength = Int32.Parse(ConfigurationManager.AppSettings["MinimumKeywordLength"]);

            if (keyword.Length < minimumKeywordLength)
            {
                MessageBox.Show("Please enter item code or item description with at least " + minimumKeywordLength.ToString() + " characters!",
                    this.Text, MessageBoxButtons.OK, MessageBoxIcon.Warning);

                txtKeyword.SelectAll();
                txtKeyword.Focus();

                return;
            }

            loadingImage.Visible = true;
            this.Refresh();

            //ThreadStart threadStart = new ThreadStart(runQuery);
            //Thread queryThread = new Thread(threadStart);
            //queryThread.Start();

            runQuery();
        }

        private void runQuery()
        {
            string keyword = txtKeyword.Text.Trim();

            btnSearch.Enabled = false;
            this.Cursor = Cursors.WaitCursor;

            string hostName = System.Net.Dns.GetHostName();
            string getBottleByLocationStoredProcedure = ConfigurationManager.AppSettings["GetBottleByLocationStoredProcedure"];
            string connectionString = ConfigurationManager.AppSettings["ConnectionString"];
            string connectionTimeout = ConfigurationManager.AppSettings["ConnectionTimeout"];

            connectionString = string.Format(connectionString, hostName);

            SqlCommand command = new SqlCommand();
            command.CommandType = CommandType.StoredProcedure;
            command.CommandText = getBottleByLocationStoredProcedure;
            command.CommandTimeout = Int32.Parse(connectionTimeout);
            command.Parameters.Add(new SqlParameter("@Keyword", keyword));

            try
            {
                SqlConnection connection = new SqlConnection(connectionString);
                connection.Open();

                command.Connection = connection;

                SqlDataReader dr = command.ExecuteReader();
                DataTable dt = new DataTable();

                dt.Load(dr);

                grdResults.DataSource = dt;
                grdResults.Columns[0].Width = 500;
                grdResults.Columns[0].Frozen = true;
                grdResults.Columns[0].DefaultCellStyle.Alignment = DataGridViewContentAlignment.MiddleLeft;

                lblResults.Text = grdResults.Rows.Count.ToString() + " items found!";
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message, this.Text, MessageBoxButtons.OK, MessageBoxIcon.Error);
            }
            finally
            {
                loadingImage.Visible = false;
                this.Refresh();

                btnSearch.Enabled = true;
                this.Cursor = Cursors.Arrow;
            }        
        }

        private void grdResults_CellFormatting(object sender, DataGridViewCellFormattingEventArgs e)
        {
            DataGridView dgv = (DataGridView)sender;

            if (e.RowIndex >= 0 && e.ColumnIndex >= 0 && dgv[e.ColumnIndex, e.RowIndex].Value is int)
            {
                if ((int)dgv[e.ColumnIndex, e.RowIndex].Value == 0)
                {
                    e.Value = "-";
                }
            }
        }
    }
}