@@ -102,19 +102,6 @@ function serialize(s::ClusterSerializer, t::Core.TypeName)
102
102
nothing
103
103
end
104
104
105
- function serialize (s:: ClusterSerializer , t:: Task )
106
- serialize_cycle (s, t) && return
107
- if istaskstarted (t) && ! istaskdone (t)
108
- error (" cannot serialize a running Task" )
109
- end
110
- writetag (s. io, TASK_TAG)
111
- serialize (s, t. code)
112
- serialize (s, t. storage)
113
- serialize (s, t. _state)
114
- serialize (s, t. result)
115
- serialize (s, t. _isexception)
116
- end
117
-
118
105
function serialize (s:: ClusterSerializer , g:: GlobalRef )
119
106
# Record if required and then invoke the default GlobalRef serializer.
120
107
sym = g. name
@@ -244,17 +231,6 @@ function deserialize(s::ClusterSerializer, t::Type{<:CapturedException})
244
231
return CapturedException (capex, bt)
245
232
end
246
233
247
- function deserialize (s:: ClusterSerializer , :: Type{Task} )
248
- t = Task (nothing )
249
- deserialize_cycle (s, t)
250
- t. code = deserialize (s)
251
- t. storage = deserialize (s)
252
- t. _state = deserialize (s):: UInt8
253
- t. result = deserialize (s)
254
- t. _isexception = deserialize (s)
255
- t
256
- end
257
-
258
234
"""
259
235
clear!(syms, pids=workers(); mod=Main)
260
236
0 commit comments