Как сохранить объект для каждого HTTP-запроса потокобезопасным способом?

Кажется, что секунды с эпохи.

In [20]: df = DataFrame(data['values'])

In [21]: df.columns = ["date","price"]

In [22]: df
Out[22]: 
<class 'pandas.core.frame.DataFrame'>
Int64Index: 358 entries, 0 to 357
Data columns (total 2 columns):
date     358  non-null values
price    358  non-null values
dtypes: float64(1), int64(1)

In [23]: df.head()
Out[23]: 
         date  price
0  1349720105  12.08
1  1349806505  12.35
2  1349892905  12.15
3  1349979305  12.19
4  1350065705  12.15
In [25]: df['date'] = pd.to_datetime(df['date'],unit='s')

In [26]: df.head()
Out[26]: 
                 date  price
0 2012-10-08 18:15:05  12.08
1 2012-10-09 18:15:05  12.35
2 2012-10-10 18:15:05  12.15
3 2012-10-11 18:15:05  12.19
4 2012-10-12 18:15:05  12.15

In [27]: df.dtypes
Out[27]: 
date     datetime64[ns]
price           float64
dtype: object
1
задан sim 22 February 2019 в 07:59
поделиться

1 ответ

Если это возможно, вам определенно следует придерживаться подхода C и передавать данные в методы и потоки явно через аргументы. Код был бы более явным. Если это невозможно, вы можете использовать что-то вроде этого:

public SomeClass{
    public static ConcurrentDictionary<Thread, HttpContextData> HttpContextData 
        = new ConcurrentDictionary<Thread, HttpContextData>();
}

// class to hold HttpContext related data
class HttpContextData { ... }


// somewhere in Asp.Net app...
ThreadStart fireAndForgetFunc = () =>
{
    var data = SomeClass.HttpContextData.GetValueOrDefault(Thread.CurrentThread);
    // work with HttpContextData
};

fireAndForgetFunc += () => 
{  
    // adding a cleanup
    SomeClass.HttpContextData.TryRemove(Thread.CurrentThread, out HttpContextData data); 
};
Thread t = new Thread(fireAndForgetFunc);

var httpContextData = new HttpContextData() {};
SomeClass.HttpContextData.TryAdd(t, httpContextData);
t.Start();

Но вы должны иметь в виду:

  1. этот код довольно хитрый и должен использоваться только как обходной путь
  2. Очистка не будет выполняться, если поток прерывается или выдает исключение.
  3. Доступ к HttpContextData возможен из более чем одного потока. В этом случае вам нужно знать о безопасности потоков.

Ответ на вопросы в комментарии

ConcurrentDictionary похож на обычный словарь, но он безопасен для потоков и может использоваться в многопоточной среде без каких-либо блокировок.

Да, словарь будет общим для всего приложения, но каждая запись в словаре будет связана с определенным thread с HttpContextData, назначенным ему во время обработки http-запроса где-то в коде asp.net.

Поскольку данные контекста перемещаются в отдельный объект, они будут вызывать изменения кода по всему дереву кода в функциях «Запустить и забыть».

он будет вызывать только изменения, как показано ниже. Изменяя это:

var data = HTTPContext.Current.GetSomeData();

на:

var data = _httpContextData.GetValueOrDefault(Thread.CurrentThread);
0
ответ дан AlbertK 22 February 2019 в 07:59
поделиться
Другие вопросы по тегам:

Похожие вопросы: