{"id":600,"date":"2021-07-09T21:35:24","date_gmt":"2021-07-10T00:35:24","guid":{"rendered":"https:\/\/millerdantas.com\/blog\/?p=600"},"modified":"2021-07-09T21:45:19","modified_gmt":"2021-07-10T00:45:19","slug":"async-nao-e-paralelismo-e-nao-async-nao-e-mesma-coisa-que-sync-parte-1","status":"publish","type":"post","link":"https:\/\/millerdantas.com\/blog\/2021\/07\/09\/async-nao-e-paralelismo-e-nao-async-nao-e-mesma-coisa-que-sync-parte-1\/","title":{"rendered":"Async n\u00e3o \u00e9 paralelismo e n\u00e3o… Async n\u00e3o \u00e9 mesma coisa que sync.- Parte 1"},"content":{"rendered":"

Intro<\/h1>\n

Calma, leia at\u00e9 o final :sweat_smile: juro que far\u00e1 sentido o t\u00edtulo, bom… pra mim fez…..<\/p>\n

N\u00e3o sei o quanto voc\u00eas conhecem de Async e a famosa maquina de estado no contexto de C#<\/p>\n

particularmente eu j\u00e1 tive v\u00e1rios problemas e cheguei odiar porque sempre tive problema e sempre culpei o compilador….<\/p>\n

bom, depois de criar vergonha na cara e meter a fu\u00e7a<\/em> em como as coisas funcionam aprendi um pouquinho, o suficiente pra n\u00e3o cair em algumas armadilhas.<\/p>\n

tenho alguns Links de refer\u00eancia como meu book of reference<\/em><\/a>, tudo que achei \u00fatil quando tive problemas eu acabei adicionando nele pra estudar aos poucos.<\/p>\n

A import\u00e2ncia de saber sobre async e sua m\u00e1quina de estado.<\/h1>\n

Recentemente fui convidado pra fazer um Code Review em um c\u00f3digo, particularmente devido o projeto que toco \u00e9 complicado fazer code-review e quando acontece \u00e9 algo bem pontual onde preciso separar na agenda.<\/p>\n

e encontrei alguns itens que me chamaram aten\u00e7\u00e3o, foi removido paralelismo, remo\u00e7\u00e3o de async e foi adicionado um tal de GC.Collect().<\/p>\n

N\u00e3o me entenda mal, mas se voc\u00ea faz isso, talvez seja importante ler o livro: Pro .Net Memory Management: For Better Code, Performance, and Scalability by Kokosa<\/a> ele d\u00e1 um background \u00f3timo sobre com funciona GC e convenhamos… A linguagem j\u00e1 tem mais de 20 anos, com engenheiros super competentes que pensaram durante anos da forma mais efici\u00eante deste processo, vamos ter humildade :sweat_smile:, existem pouqu\u00edssimos casos que voc\u00ea realmente precisa fazer isso, pelo que me recordo em debugging ou fazendo benchmark, com excess\u00e3o desses pontos, voc\u00ea vai apenas piorar a heur\u00edstica e se ele est\u00e1 sendo o problema… novamente, leia o livro do Kokosa e comece usar o Stack.<\/p>\n

bom pulando pra parte que eu queria falar :sleeping:<\/p>\n

Async at last!<\/h1>\n

n\u00e3o sei se voc\u00eas tem o costume de ler o que o c\u00f3digo vai gerar ao escrever o c\u00f3digo, n\u00e3o \u00e9 sempre que voc\u00ea precisa disso, na verdade voc\u00ea ignora essa parte porque s\u00e3o poucos cen\u00e1rios que voc\u00ea precisar\u00e1 entender o que acontece por tr\u00e1s do c\u00f3digo gerado ou IL pra determinar uma nova forma de escrever c\u00f3digo<\/p>\n

um c\u00f3digo simples :<\/p>\n

using System;\nusing System.Threading.Tasks;\npublic class TestSubject {\n    public void DoSomething() {\n    }\n    public async Task DoSomethingAsync() {\n    }\n}\n\n<\/code><\/pre>\n
e o compilador ir\u00e1 traduzir isso para:<\/p>\n
using System;\nusing System.Diagnostics;\nusing System.Reflection;\nusing System.Runtime.CompilerServices;\nusing System.Security;\nusing System.Security.Permissions;\nusing System.Threading.Tasks;\n\n[assembly: CompilationRelaxations(8)]\n[assembly: RuntimeCompatibility(WrapNonExceptionThrows = true)]\n[assembly: Debuggable(DebuggableAttribute.DebuggingModes.Default | DebuggableAttribute.DebuggingModes.DisableOptimizations | DebuggableAttribute.DebuggingModes.IgnoreSymbolStoreSequencePoints | DebuggableAttribute.DebuggingModes.EnableEditAndContinue)]\n[assembly: SecurityPermission(SecurityAction.RequestMinimum, SkipVerification = true)]\n[assembly: AssemblyVersion(\"0.0.0.0\")]\n[module: UnverifiableCode]\npublic class TestSubject\n{\n    [CompilerGenerated]\n    private sealed class <DoSomethingAsync>d__1 : IAsyncStateMachine\n    {\n        public int <>1__state;\n\n        public AsyncTaskMethodBuilder <>t__builder;\n\n        public TestSubject <>4__this;\n\n        private void MoveNext()\n        {\n            int num = <>1__state;\n            try\n            {\n            }\n            catch (Exception exception)\n            {\n                <>1__state = -2;\n                <>t__builder.SetException(exception);\n                return;\n            }\n            <>1__state = -2;\n            <>t__builder.SetResult();\n        }\n\n        void IAsyncStateMachine.MoveNext()\n        {\n            \/\/ILSpy generated this explicit interface implementation from .override directive in MoveNext\n            this.MoveNext();\n        }\n\n        [DebuggerHidden]\n        private void SetStateMachine(IAsyncStateMachine stateMachine)\n        {\n        }\n\n        void IAsyncStateMachine.SetStateMachine(IAsyncStateMachine stateMachine)\n        {\n            \/\/ILSpy generated this explicit interface implementation from .override directive in SetStateMachine\n            this.SetStateMachine(stateMachine);\n        }\n    }\n\n    public void DoSomething()\n    {\n    }\n\n    [AsyncStateMachine(typeof(<DoSomethingAsync>d__1))]\n    [DebuggerStepThrough]\n    public Task DoSomethingAsync()\n    {\n        <DoSomethingAsync>d__1 stateMachine = new <DoSomethingAsync>d__1();\n        stateMachine.<>t__builder = AsyncTaskMethodBuilder.Create();\n        stateMachine.<>4__this = this;\n        stateMachine.<>1__state = -1;\n        stateMachine.<>t__builder.Start(ref stateMachine);\n        return stateMachine.<>t__builder.Task;\n    }\n}\n\n<\/code><\/pre>\n
\u00e9 poss\u00edvel perceber que toda vez que voc\u00ea deixa uma assinatura de “async” no m\u00e9todo ele gera uma m\u00e1quina de estado, \u00e9 at\u00e9 um dos motivos que eu tento n\u00e3o criar nested async<\/em>, afinal invari\u00e1velmente ser\u00e1 alocado em mem\u00f3ria, ent\u00e3o em cen\u00e1rios cr\u00edticos eu penso bem… Continuando….<\/p>\n
Precisava dar esse contexto caso algu\u00e9m n\u00e3o tivesse ainda a oportunidade de  saber o que acontece por baixo dos panos, ent\u00e3o foi um resumo pra continuar<\/p>\n
em minha mem\u00f3ria do c\u00f3digo de algum tempo atr\u00e1s era o seguinte:<\/p>\n
public async Task SomeMainTask(){\n\n    var id = 0;\n    var processoUm = Task.Run(()=>{ id = DoSomething();});\n    var processoDois = DoOtherThing();\n\n    await processoUm;\n\n    (... outros processos sincronos e ass\u00edncronos)\n\n    var processoDois = DoOtherThing(id);\n\n    Task.WaitAll(\n        processoDois,\n        (...)\n    );\n}\n\npublic async Task<id> DoSomething(){\n    (... alguma chamada pro banco)\n    \/\/\/c\u00f3digo apenas pra contexto\n    return Task.FromResult(id);\n\n}\n\n<\/code><\/pre>\n
e quando eu li o c\u00f3digo:<\/p>\n
public void  SomeMainTask(){\n\n    var id = 0;\n    var processoUm = DoSomething();\n    var processoDois = DoOtherThing();\n\n    (... outros processos sincronos e ass\u00edncronos)\n\n    var processoDois = DoOtherThing(id);    \n}\n\npublic id DoSomething(){\n    (... alguma chamada pro banco)\n    \/\/\/c\u00f3digo apenas pra contexto\n    return id;\n\n}\n\n<\/code><\/pre>\n
eu fiquei meio intrigado, eu queria entender a motiva\u00e7\u00e3o… particularmente eu fa\u00e7o tudo sincrono mesmo e eventualmente quando estou fazendo meu pr\u00f3prio code-review eu penso se faz ou n\u00e3o sentido colocar um async.<\/p>\n
quando questionei, a resposta foi que async e sincrono seriam as mesmas coisas no final das contas  ou seja :<\/p>\n
isso<\/p>\n
var id = DoSomething();\n\npublic int DoSomething(){\n    (...chamada pro banco)\n    return someid;\n}\n<\/code><\/pre>\n
\u00e9 igual isso:<\/p>\n
var id = await DoSomething();\n\npublic Task<int> DoSomething(){\n    (...chamada pro banco)\n    using(var someconn = new SqlConnection(connectionstring)){\n        return someconn.FirstOrDefaultAsync<int>(\"select 1\");   \n    }   \n}\n<\/code><\/pre>\n
ser\u00e1?<\/p>\n
tentei explicar que n\u00e3o era… afinal na pr\u00f3pria documenta\u00e7\u00e3o da microsoft<\/a> (inclusive… que maravilha de doc ) explica exatamente o que eu disse. Apesar do meu esfor\u00e7o de mostrar que ele vai bloquear uma thread at\u00e9 ter resposta…<\/p>\n
achei mais simples criar um c\u00f3digo muito simples pra apresentar o problema:<\/p>\n
Apenas pra dar contexto, eu sou um usu\u00e1rio ass\u00edduo do LinqPad, logo quando estiver escrito “someText”.Dump(); no c\u00f3digo abaixo, entenda como Console.WriteLine(“sometext”);<\/p>\n
async System.Threading.Tasks.Task Main()\n{\n    int nWorkers; \n    int nCompletions; \n\n    \/\/\/aqui estou for\u00e7ando que apenas exista uma \u00fanica Thread no meu sistema pra apresentar um cen\u00e1rio que d\u00e1 pra observar o comportamento\n    ThreadPool.SetMinThreads(1, 1).Dump();\n    ThreadPool.SetMaxThreads(1, 1).Dump();\n\n    \/\/\/ apenas me assegurando que \u00e9 apenas uma thread..... vai que... \n    ThreadPool.GetMaxThreads(out nWorkers, out nCompletions);\n        \"workers: {nWorkers}\".Dump();<\/span>\"nCompletions: {nWorkers}\".Dump();\n\n    \/\/\/estou deixando uma thread executando sem parar, com um intervalo de 2 segundos, como se fosse um heart-beat.\n    System.Threading.Tasks.Task.Run(async ()=>{\n                while(true){\n                    \"Heartbeat\".Dump();\n                     await System.Threading.Tasks.Task.Delay(2000);\n                }\n    });\n\n\n    for(var i = 0; i<=4; i++){\n        \/\/\/ aqui estou criando algumas Tasks ass\u00edncronas para executar alguma a\u00e7\u00e3o representando um insert no banco.\n        await System.Threading.Tasks.Task.Run(async ()=>{\n                await System.Threading.Tasks.Task.Delay(5000);<\/span>\"{Thread.CurrentThread.ManagedThreadId}-{DateTime.Now.ToString(\"HH:MM:ss\")}\".Dump();\n        });\n    }\n\n    \"-----------------------Async Done-----------------------\".Dump();\n    for(var i = 0; i<=4; i++){\n        \/\/\/ aqui estou criando as mesmas Tasks mas desta vez estou for\u00e7ando a execu\u00e7\u00e3o s\u00edncrona para executar a mesma a\u00e7\u00e3o no banco.\n            System.Threading.Tasks.Task.Run(()=>{\n                System.Threading.Tasks.Task.Delay(5000).Wait();\n                $\"{i} - {Thread.CurrentThread.ManagedThreadId}-{DateTime.Now.ToString(\"HH:MM:ss\")}\".Dump();\n            });\n    }\n}\n<\/code><\/pre>\n
O que voc\u00ea acha que aconteceu?<\/p>\n
eu tive que gravar um v\u00eddeo…:sweat_smile:<\/p>\n