无法处理ThreadAbortException

我有一个WCF服务，它接受请求，并为每个请求调用HTTPWebRequest并返回响应。我使用BlockingCollection来存储传入的请求，并使用一个单独的线程处理集合中的项(使webrequest)。有时Webrequest返回threadabortexception。我捕获它并执行Thread.ResetAbort。但是异常向上流动并且它清除了BlockingCollection。我添加了下面的代码片段。我需要找到一种方法为foreach循环保持继续，即使我得到一个threadabort异常。

public static class YBProcessor
{
    static PriorityQueue<QueuePriorityLevel, string> queue = new PriorityQueue<QueuePriorityLevel, string>();
    static BlockingCollection<KeyValuePair<QueuePriorityLevel, string>> requests;
    static YBProcessor()
    {        
        requests = new BlockingCollection<KeyValuePair<QueuePriorityLevel, string>>(queue);
        Task.Factory.StartNew(() => SendRequestToYB());
    }
    public static void AddCalcRequest(string cusip, double price, QueuePriorityLevel priority)
    {
         requests.Add(new KeyValuePair<QueuePriorityLevel, string>(priority, cusip + "-" + price.ToString()));                                          
    }
   private static void SendRequestToYB()
   {
       // this is a separate thread that processes the requests as the come in.
      foreach (var obj in requests.GetConsumingEnumerable())
      {                 
          try
          {
            var request = GetXML(obj.Value);
            var response = YBClient.GetResponse(request);
            //code to handle response
          }
          catch (ThreadAbortException ex)
          {
            Thread.ResetAbort();
          }
          catch (Exception ex)
          {
          }
       }    
     }
}

//在YBClient的GetResponse方法(只是关键部分。代码无法编译)

private static String GetResponse(String text)
{
    for (iTry = 0; iTry < MAX_TRY; iTry++)
    {
        try
        {
            // Create and setup request
            bytes = encoding.GetBytes(text);
            request = (HttpWebRequest)WebRequest.Create(uri);
            request.Method = "POST";
            request.ContentType = "text/xml";
            request.ContentLength = bytes.Length;
            request.CookieContainer = cookieJar;
            request.Timeout = 100 * 1000;
            request.ReadWriteTimeout = 100 * 1000;
            // Prepare and send data
            postStream = request.GetRequestStream();
            postStream.Write(bytes, 0, bytes.Length);
            postStream.Close();
            // Get response from server
            response = (HttpWebResponse)request.GetResponse();
            if (response.StatusCode == HttpStatusCode.OK)
            {
                reader = new StreamReader(response.GetResponseStream(), encoding);
                xmlResponse = reader.ReadToEnd();
                reader.Close();
                break;
            }               
            response.Close();
        }
        catch (ThreadAbortException ex)
        {
            Thread.ResetAbort();                
            break;              
        }           
        catch (Exception ex)
        {               
            if (ex.GetBaseException() is ThreadAbortException)
            {                   
                Thread.ResetAbort();
                break;
            }
        }
    }       
}
return xmlResponse;
}