Forwarded from Stanislav Popov
топ статья https://habr.com/ru/post/476916/
Хабр
Я больше не хочу работать, никогда и ни над чем. Но из меня научились выжимать результаты
Дерьмовое утро удалёнщика всегда начинается одинаково. Если детский плач не смог вытащить меня из кровати, то нытье жены сделает это с гарантией. Сумасшедшие девять утра, через час дейли-синк-ап, а за...
Forwarded from Денис
pub fn run<F, I>(f: F) -> CpuFuture<I>
where
F: FnOnce() -> I + Send + 'static,
I: Send + 'static,
{
let (tx, rx) = oneshot::channel();
POOL.with(|pool| {
pool.execute(move || {
if !tx.is_canceled() {
let _ = tx.send(f());
}
})
});
CpuFuture { rx }
}Forwarded from Денис
типа если конец канала дропнули до того, как фактически началось выполнение, то оно и не начнётся
Александр Мещеряков:
Всем привет! Помогите разобраться с ошибкой десериализации в serde:
Делаю так:
#[derive(Debug, PartialEq, Eq, Clone, Copy, Serialize, Deserialize)]
#[serde(try_from = "String")]
pub struct CurrencyId(&'static str);
impl TryFrom<String> for CurrencyId {
type Error = String;
fn try_from(value: String) -> Result<Self, Self::Error> {
Ok(Self(Box::leak(value.into_boxed_str())))
}
}
Но при компиляции простой структуры, которая содержит поле CurrencyId, получаю ошибку:
error[E0495]: cannot infer an appropriate lifetime for lifetime parameter
--> test/src/mod.rs:62:5
|
62 | pub currency_id: CurrencyId,
| ^^^
|
note: first, the lifetime cannot outlive the lifetime 'de as defined on the impl at 60:50...
--> test/src/mod.rs:60:50
|
60 | #[derive(Debug, PartialEq, Eq, Clone, Serialize, Deserialize)]
| ^^^^^^^^^^^
= note: ...so that the types are compatible:
expected matching::_IMPL_DESERIALIZE_FOR_MatchingStatus::_serde::de::SeqAccess<'_>
found matching::_IMPL_DESERIALIZE_FOR_MatchingStatus::_serde::de::SeqAccess<'de>
= note: but, the lifetime must be valid for the static lifetime...
= note: ...so that the types are compatible:
expected matching::_IMPL_DESERIALIZE_FOR_MatchingStatus::_serde::Deserialize<'_>
found matching::_IMPL_DESERIALIZE_FOR_MatchingStatus::_serde::Deserialize<'static>
Kitsu:
Нельзя десериализовывать static в принципе, это невалидно. 'static - то, что известно на этапе компиляции. Вам подойдет либо owned структура (String), либо строчка с лайфтаймом (&'a str) от того места, откуда идет десериализации (см. доку серде по аттрибутам).
лан, на самом деле на счет "известно на этапе компиляции" я преувеличил, но истина где-то рядом
Александр Мещеряков:
Но там же стоит #[serde(try_from = "String")], какая ему разница, как я получу данный тип из строки? И да, я могу получить статический строковый срез на этапе выполнения.
Kitsu:
А когда вызвать деструктор у строки?
Этот вариант подразумевает, что в коде будет что-то типо:
fn deserialize<D: Deserialize>(d: D) -> Result<MyType> {
let s: String = d.deserialize_string()?;
let my_type = s.try_from()?;
Ok(my_type)
}
s: String - умерла при выходе из функции, а my_type — нет
red75prime:
Главный вопрос. Куда &str должен указывать? serde по понятным причинам не делает Box::leak(), чтобы получить 'static ссылки.
Александр Мещеряков:
try_from делает Box::leak(value.into_boxed_str()), или я не понял, что вы имеете ввиду
Ну у меня есть TryFrom который гарантированно работает - переводит String в CurrencyId, что-то не пойму, почему этого не достаточно
red75prime:
А зачем такое... неортодоксальное решение? Почему не String или Box<str>?
Александр Мещеряков:
Ну мне нужен именно &'static str в CurrencyId, и этот срез будет браться из статического сервиса, но для упрощения примера я сделал Box::leak для получения &'static str из String
Сути ошибки это не изменило...
red75prime:
Хм. Разве что попробовать #[serde(bound(deserialize = "T: DeserializeOwned"))] на поле currency_id. Даже лучше на типе CurrencyId
Александр Мещеряков:
red75prime @kitsu В общем, единственно работающим вариантом оказалось написать собственный десериализатор:
impl<'de> Deserialize<'de> for CurrencyId {
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: Deserializer<'de>,
{
let value = String::deserialize(deserializer)?;
CurrencyId::try_from(value).map_err(<D::Error as de::Error>::custom)
}
}
Мне кажется это баг в serde, он по идее не должен был вообще учитывать статический лайфтайм если я использую TryFrom. Наверное стоит создать issue.
Всем привет! Помогите разобраться с ошибкой десериализации в serde:
Делаю так:
#[derive(Debug, PartialEq, Eq, Clone, Copy, Serialize, Deserialize)]
#[serde(try_from = "String")]
pub struct CurrencyId(&'static str);
impl TryFrom<String> for CurrencyId {
type Error = String;
fn try_from(value: String) -> Result<Self, Self::Error> {
Ok(Self(Box::leak(value.into_boxed_str())))
}
}
Но при компиляции простой структуры, которая содержит поле CurrencyId, получаю ошибку:
error[E0495]: cannot infer an appropriate lifetime for lifetime parameter
'de due to conflicting requirements--> test/src/mod.rs:62:5
|
62 | pub currency_id: CurrencyId,
| ^^^
|
note: first, the lifetime cannot outlive the lifetime 'de as defined on the impl at 60:50...
--> test/src/mod.rs:60:50
|
60 | #[derive(Debug, PartialEq, Eq, Clone, Serialize, Deserialize)]
| ^^^^^^^^^^^
= note: ...so that the types are compatible:
expected matching::_IMPL_DESERIALIZE_FOR_MatchingStatus::_serde::de::SeqAccess<'_>
found matching::_IMPL_DESERIALIZE_FOR_MatchingStatus::_serde::de::SeqAccess<'de>
= note: but, the lifetime must be valid for the static lifetime...
= note: ...so that the types are compatible:
expected matching::_IMPL_DESERIALIZE_FOR_MatchingStatus::_serde::Deserialize<'_>
found matching::_IMPL_DESERIALIZE_FOR_MatchingStatus::_serde::Deserialize<'static>
Kitsu:
Нельзя десериализовывать static в принципе, это невалидно. 'static - то, что известно на этапе компиляции. Вам подойдет либо owned структура (String), либо строчка с лайфтаймом (&'a str) от того места, откуда идет десериализации (см. доку серде по аттрибутам).
лан, на самом деле на счет "известно на этапе компиляции" я преувеличил, но истина где-то рядом
Александр Мещеряков:
Но там же стоит #[serde(try_from = "String")], какая ему разница, как я получу данный тип из строки? И да, я могу получить статический строковый срез на этапе выполнения.
Kitsu:
А когда вызвать деструктор у строки?
Этот вариант подразумевает, что в коде будет что-то типо:
fn deserialize<D: Deserialize>(d: D) -> Result<MyType> {
let s: String = d.deserialize_string()?;
let my_type = s.try_from()?;
Ok(my_type)
}
s: String - умерла при выходе из функции, а my_type — нет
red75prime:
Главный вопрос. Куда &str должен указывать? serde по понятным причинам не делает Box::leak(), чтобы получить 'static ссылки.
Александр Мещеряков:
try_from делает Box::leak(value.into_boxed_str()), или я не понял, что вы имеете ввиду
Ну у меня есть TryFrom который гарантированно работает - переводит String в CurrencyId, что-то не пойму, почему этого не достаточно
red75prime:
А зачем такое... неортодоксальное решение? Почему не String или Box<str>?
Александр Мещеряков:
Ну мне нужен именно &'static str в CurrencyId, и этот срез будет браться из статического сервиса, но для упрощения примера я сделал Box::leak для получения &'static str из String
Сути ошибки это не изменило...
red75prime:
Хм. Разве что попробовать #[serde(bound(deserialize = "T: DeserializeOwned"))] на поле currency_id. Даже лучше на типе CurrencyId
Александр Мещеряков:
red75prime @kitsu В общем, единственно работающим вариантом оказалось написать собственный десериализатор:
impl<'de> Deserialize<'de> for CurrencyId {
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: Deserializer<'de>,
{
let value = String::deserialize(deserializer)?;
CurrencyId::try_from(value).map_err(<D::Error as de::Error>::custom)
}
}
Мне кажется это баг в serde, он по идее не должен был вообще учитывать статический лайфтайм если я использую TryFrom. Наверное стоит создать issue.
Linker Unsafe
Photo
Vlad Beskrovnyy:
Ну, вот MIR простой функции, состоящей из двух await'ов других функций (и больше ничего). Я этот свитч имею в виду
Здесь _1 - это первый параметр, т.е. self, т.е. сама реализация фьючера. Видно, что это enum. В _21 записывается дискриминант енама, дальше по нему свитчимся. Ну, собственно, стейтмашина, че...
Kai Ren:
Спасибо за пояснения. Я как-то MIR читать не привык.
Попробуй сделать на чистых футурах без async/.await. Вполне возможно это все те же пляски с генераторами. Там сейчас внутри генератором есть мувы, и это, кстати, боком вылазит в юзер коде с async move {} блоками требую либо Copy либо дополнительных явных клонов.
Vlad Beskrovnyy:
Ну, я бы так не сказал, вроде бы от этого свитча фундаментально не избавиться. Мне просто интересно, почему была выбрана именно такая модель фьючеров, с поллингом всей цепочки. Понимаю, что она была выбрана уже много лет назад, и, вероятно, все уже забыли, но тогда этот выбор должен был быть хорошо мотивирован, полагаю
Вроде звучит разумно, но вот интересно, с тех пор как оно там все Pin, т.е. не может муваться, разве нельзя без аллокаций. А, хотя фьючеры могут быть Unpin...
Ну, вот MIR простой функции, состоящей из двух await'ов других функций (и больше ничего). Я этот свитч имею в виду
Здесь _1 - это первый параметр, т.е. self, т.е. сама реализация фьючера. Видно, что это enum. В _21 записывается дискриминант енама, дальше по нему свитчимся. Ну, собственно, стейтмашина, че...
Kai Ren:
Спасибо за пояснения. Я как-то MIR читать не привык.
Попробуй сделать на чистых футурах без async/.await. Вполне возможно это все те же пляски с генераторами. Там сейчас внутри генератором есть мувы, и это, кстати, боком вылазит в юзер коде с async move {} блоками требую либо Copy либо дополнительных явных клонов.
Vlad Beskrovnyy:
Ну, я бы так не сказал, вроде бы от этого свитча фундаментально не избавиться. Мне просто интересно, почему была выбрана именно такая модель фьючеров, с поллингом всей цепочки. Понимаю, что она была выбрана уже много лет назад, и, вероятно, все уже забыли, но тогда этот выбор должен был быть хорошо мотивирован, полагаю
Вроде звучит разумно, но вот интересно, с тех пор как оно там все Pin, т.е. не может муваться, разве нельзя без аллокаций. А, хотя фьючеры могут быть Unpin...
Forwarded from A64m AL256m qn<cores> I0
ну вот теперь точно
УЛЬТИМЕЙТ 8.10 СНИППЕТ
УЛЬТИМЕЙТ 8.10 СНИППЕТ
{-# language UnliftedNewtypes #-}
{-# language StandaloneKindSignatures #-}
{-# language DataKinds, PolyKinds, ExplicitForAll #-}
{-# language ImportQualifiedPost #-}
{-# language MagicHash, UnboxedTuples #-}
module Foo where
import GHC.Types
import GHC.Prim qualified as Prim
type Arr :: forall k -> k -> TYPE(TupleRep[Int32Rep,Int32Rep,AddrRep])
newtype Arr k a = Arr (# Prim.Int32#, Prim.Int32#, Prim.Addr# #)