Попробуйте следующее:
class a
{
Form f1;
a(Form f){
f1 = f;
}
private void aa()
{
f1.b();
}
}
public partial class Form2 : form
{
public void b()
{
textbox1.text= "xyz";
}
private void button1.Clicked(args, events){
a obj = new a(this.Form);
obj.aa();
}
}
Я не думаю, что вам нужен обратный резерв, потому что, если вы получаете больше, чем обрабатываете все время, это выделит всю память и исключение курса в вашем случае, но я думаю, что выбор состоит в том, чтобы создать источник излучения, в котором каждый поток посылает элемент этому эмиттер и использовать mongorepo.saveAll (эмиттер):
процессор1 ->
процессор2 ->
процессор3 ->
процессор4 ->
[ 115] processor5 -> EMITTING EMITTER - EMITTER СОХРАНИТЬ В MONGO с помощью saveAll (эмиттер)
процессор6 ->
процессор7 ->
процессор8 ->
[119 ] процессор9 ->
процессор10 ->